admin/milvus
1
0
Fork 0
mirror of https://gitee.com/milvus-io/milvus.git synced 2025-12-06 17:18:35 +08:00
Code Issues Packages Projects Releases Wiki Activity

fix: [StorageV2] sync panic with add field (#42932)

Browse Source 
related: #39663

Signed-off-by: shaoting-huang <shaoting.huang@zilliz.com>
This commit is contained in:
sthuang 2025-06-25 10:08:40 +08:00 committed by GitHub
parent 0c0eb74ce5
commit d4260b47fa
No known key found for this signature in database
GPG Key ID: B5690EEEBB952194
1 changed files with 4 additions and 4 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

8
internal/flushcommon/syncmgr/pack_writer_v2.go
View File

@ -187,7 +187,7 @@ func (bw *BulkPackWriterV2) splitInsertData(insertData []*storage.InsertData, sp
if len(uniqueRows) != 1 || uniqueRows[0] == 0 {
return nil, errors.New("row num is not equal for each field")
}
for i, field := range bw.metaCache.Schema().GetFields() {
for i, field := range bw.schema.GetFields() {
if _, ok := memorySizes[field.FieldID]; !ok {
return nil, fmt.Errorf("field %d not found in insert data", field.FieldID)
}
@ -218,15 +218,15 @@ func (bw *BulkPackWriterV2) serializeBinlog(ctx context.Context, pack *SyncPack)
defer builder.Release()
for _, chunk := range pack.insertData {
if err := storage.BuildRecord(builder, chunk, bw.metaCache.Schema().GetFields()); err != nil {
if err := storage.BuildRecord(builder, chunk, bw.schema.GetFields()); err != nil {
return nil, err
}
}
rec := builder.NewRecord()
field2Col := make(map[storage.FieldID]int, len(bw.metaCache.Schema().GetFields()))
field2Col := make(map[storage.FieldID]int, len(bw.schema.GetFields()))
for c, field := range bw.metaCache.Schema().GetFields() {
for c, field := range bw.schema.GetFields() {
field2Col[field.FieldID] = c
}
return storage.NewSimpleArrowRecord(rec, field2Col), nil