aboutsummaryrefslogtreecommitdiff
diff options
context:
space:
mode:
authorchrislu <chris.lu@gmail.com>2024-04-28 13:56:55 -0700
committerchrislu <chris.lu@gmail.com>2024-04-28 13:56:55 -0700
commitb570e015ce5125fda80e3bc1de4255223c44fc4c (patch)
treeca1ea674a010f3aa35a9e4534f3a65000330e2b1
parent5dc186ef01b7c5faf655df39b3adc86ff8e8d3dc (diff)
downloadseaweedfs-b570e015ce5125fda80e3bc1de4255223c44fc4c.tar.xz
seaweedfs-b570e015ce5125fda80e3bc1de4255223c44fc4c.zip
Update write_parquet_test.go
-rw-r--r--weed/mq/schema/write_parquet_test.go2
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 5b4887556..19576cfdd 100644
--- a/weed/mq/schema/write_parquet_test.go
+++ b/weed/mq/schema/write_parquet_test.go
@@ -87,7 +87,7 @@ func testWritingParquetFile(t *testing.T, count int, filename string, parquetSch
fmt.Sprintf("john_%d@e.com", i)).
RecordEnd()).
SetString("Company", fmt.Sprintf("company_%d", i)).
- RecordEnd()
+ RecordEnd()
AddRecordValue(rowBuilder, recordType, parquetLevels, recordValue)
if count < 10 {