aboutsummaryrefslogtreecommitdiff
path: root/weed/mq/schema/to_parquet_schema.go
diff options
context:
space:
mode:
Diffstat (limited to 'weed/mq/schema/to_parquet_schema.go')
-rw-r--r--weed/mq/schema/to_parquet_schema.go2
1 files changed, 1 insertions, 1 deletions
diff --git a/weed/mq/schema/to_parquet_schema.go b/weed/mq/schema/to_parquet_schema.go
index 196546a32..036acc153 100644
--- a/weed/mq/schema/to_parquet_schema.go
+++ b/weed/mq/schema/to_parquet_schema.go
@@ -9,7 +9,7 @@ import (
func ToParquetSchema(topicName string, recordType *schema_pb.RecordType) (*parquet.Schema, error) {
rootNode, err := toParquetFieldTypeRecord(recordType)
if err != nil {
- return nil, fmt.Errorf("failed to convert record type to parquet schema: %v", err)
+ return nil, fmt.Errorf("failed to convert record type to parquet schema: %w", err)
}
// Fields are sorted by name, so the value should be sorted also