record type is also optional

8 months ago · 30b5aef62e
1 changed files with 1 additions and 0 deletions
--- a/weed/mq/schema/to_parquet_schema.go
+++ b/weed/mq/schema/to_parquet_schema.go
@ -24,6 +24,7 @@ func toParquetFieldType(fieldType *schema_pb.Type) (dataType parquet.Node, err e
 		dataType = parquet.Optional(dataType)
 	case *schema_pb.Type_RecordType:
 		dataType, err = toParquetFieldTypeRecord(fieldType.GetRecordType())
+		dataType = parquet.Optional(dataType)
 	case *schema_pb.Type_ListType:
 		dataType, err = toParquetFieldTypeList(fieldType.GetListType())
 	default: