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