admin/milvus
1
0
Fork 0
mirror of https://gitee.com/milvus-io/milvus.git synced 2026-02-02 01:06:41 +08:00
Code Issues Packages Projects Releases Wiki Activity

fix: add check for WriteRecordBatch (#47137)

Browse Source 
fix for https://github.com/milvus-io/milvus/issues/47073

---------

Signed-off-by: Xinyi Jiang <xinyi.jiang@reddit.com>
Co-authored-by: Xinyi Jiang <xinyi.jiang@reddit.com>
This commit is contained in:
Xinyi7 2026-01-25 12:11:32 -05:00 committed by GitHub
parent e092884822
commit 610bc045da
No known key found for this signature in database
GPG Key ID: B5690EEEBB952194
1 changed files with 4 additions and 0 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

4
internal/storagev2/packed/packed_writer.go
View File

@ -128,6 +128,10 @@ func NewPackedWriter(filePaths []string, schema *arrow.Schema, bufferSize int64,
}
func (pw *PackedWriter) WriteRecordBatch(recordBatch arrow.Record) error {
if recordBatch == nil || recordBatch.NumCols() == 0 {
return nil
}
cArrays := make([]CArrowArray, recordBatch.NumCols())
cSchemas := make([]CArrowSchema, recordBatch.NumCols())