diff options
| author | chrislu <chris.lu@gmail.com> | 2025-03-04 08:14:29 -0800 |
|---|---|---|
| committer | chrislu <chris.lu@gmail.com> | 2025-03-04 08:14:31 -0800 |
| commit | 2259662c7b65ac755bac2ef24a4ab2ce39e5b57d (patch) | |
| tree | 6f5df92f0e7814fe020da52c13cdfefb2c590461 | |
| parent | 91a963190458f4ad7f677e8566d61ce42c4a4487 (diff) | |
| download | seaweedfs-2259662c7b65ac755bac2ef24a4ab2ce39e5b57d.tar.xz seaweedfs-2259662c7b65ac755bac2ef24a4ab2ce39e5b57d.zip | |
adjust logs
| -rw-r--r-- | weed/mq/schema/write_parquet_test.go | 6 |
1 files changed, 3 insertions, 3 deletions
diff --git a/weed/mq/schema/write_parquet_test.go b/weed/mq/schema/write_parquet_test.go index 5cfdec999..f7ab26860 100644 --- a/weed/mq/schema/write_parquet_test.go +++ b/weed/mq/schema/write_parquet_test.go @@ -91,13 +91,13 @@ func testWritingParquetFile(t *testing.T, count int, filename string, parquetSch AddRecordValue(rowBuilder, recordType, parquetLevels, recordValue) if count < 10 { - fmt.Printf("RecordValue: %v\n", recordValue) + fmt.Printf("Write RecordValue: %v\n", recordValue) } row := rowBuilder.Row() if count < 10 { - fmt.Printf("Row: %+v\n", row) + fmt.Printf("Build Row: %+v\n", row) } if err != nil { @@ -143,7 +143,7 @@ func testReadingParquetFile(t *testing.T, filename string, parquetSchema *parque t.Fatalf("ToRecordValue failed: %v", err) } if rowCount < 10 { - fmt.Printf("RecordValue: %v\n", recordValue) + fmt.Printf("Read RecordValue: %v\n", recordValue) } } total += rowCount |