From b2016ab9b6ac036b777d7db1a97c90bdcbc153ab Mon Sep 17 00:00:00 2001 From: chrislu Date: Fri, 12 Sep 2025 17:49:29 -0700 Subject: [PATCH] fix build --- weed/mq/logstore/read_parquet_to_log.go | 6 +++--- 1 file changed, 3 insertions(+), 3 deletions(-) diff --git a/weed/mq/logstore/read_parquet_to_log.go b/weed/mq/logstore/read_parquet_to_log.go index d465d112d..e3c18c884 100644 --- a/weed/mq/logstore/read_parquet_to_log.go +++ b/weed/mq/logstore/read_parquet_to_log.go @@ -78,7 +78,7 @@ func GenParquetReadFunc(filerClient filer_pb.FilerClient, t topic.Topic, p topic recordType = schema.NewRecordTypeBuilder(recordType). WithField(SW_COLUMN_NAME_TS, schema.TypeInt64). WithField(SW_COLUMN_NAME_KEY, schema.TypeBytes). - WithField(SW_COLUMN_NAME_INDEX, schema.TypeInt64). + WithField(SW_COLUMN_NAME_OFFSET, schema.TypeInt64). RecordTypeEnd() parquetLevels, err := schema.ToParquetLevels(recordType) @@ -124,8 +124,8 @@ func GenParquetReadFunc(filerClient filer_pb.FilerClient, t topic.Topic, p topic // Get offset from parquet, default to 0 if not present (backward compatibility) var offset int64 = 0 - if indexValue, exists := recordValue.Fields[SW_COLUMN_NAME_INDEX]; exists { - offset = indexValue.GetInt64Value() + if offsetValue, exists := recordValue.Fields[SW_COLUMN_NAME_OFFSET]; exists { + offset = offsetValue.GetInt64Value() } logEntry := &filer_pb.LogEntry{