fix: BinlogDeserializeReader leak (#36087)

https://github.com/milvus-io/milvus/issues/36086

Signed-off-by: fengjun2016 <jornfeng@gmail.com>
pull/36142/head
CharlesFeng 2024-09-10 12:43:07 +08:00 committed by GitHub
parent f4d0c589fa
commit 4850641943
No known key found for this signature in database
GPG Key ID: B5690EEEBB952194
1 changed files with 2 additions and 0 deletions

View File

@ -381,6 +381,7 @@ func (st *statsTask) downloadData(ctx context.Context, numRows int64, PKFieldID
break
} else {
log.Warn("downloadData wrong, failed to iter through data", zap.Error(err))
iter.Close()
return nil, err
}
}
@ -399,6 +400,7 @@ func (st *statsTask) downloadData(ctx context.Context, numRows int64, PKFieldID
values = append(values, iter.Value())
remainingRowCount++
}
iter.Close()
}
log.Info("download data success",