diff options
| author | chrislu <chris.lu@gmail.com> | 2024-04-25 22:02:03 -0700 |
|---|---|---|
| committer | chrislu <chris.lu@gmail.com> | 2024-04-25 22:02:03 -0700 |
| commit | 63036133ffa04efc95f8751435ef6b80711c6657 (patch) | |
| tree | 9296d589fa19da36469bec154aa854f6fd01a63a | |
| parent | 2a9b0a9332aa9accf4186c65663e83ac15a50b91 (diff) | |
| download | seaweedfs-63036133ffa04efc95f8751435ef6b80711c6657.tar.xz seaweedfs-63036133ffa04efc95f8751435ef6b80711c6657.zip | |
minor
| -rw-r--r-- | weed/mq/schema/write_parquet_test.go | 2 |
1 files changed, 1 insertions, 1 deletions
diff --git a/weed/mq/schema/write_parquet_test.go b/weed/mq/schema/write_parquet_test.go index 454b6cdc4..928dab1d3 100644 --- a/weed/mq/schema/write_parquet_test.go +++ b/weed/mq/schema/write_parquet_test.go @@ -58,7 +58,7 @@ func testWritingParquetFile(t *testing.T, count int, filename string, parquetSch t.Fatalf("os.Open failed: %v", err) } defer file.Close() - writer := parquet.NewWriter(file, parquetSchema, parquet.Compression(&zstd.Codec{Level: zstd.SpeedDefault})) + writer := parquet.NewWriter(file, parquetSchema, parquet.Compression(&zstd.Codec{Level: zstd.DefaultLevel})) rowBuilder := parquet.NewRowBuilder(parquetSchema) for i := 0; i < count; i++ { rowBuilder.Reset() |