From 610bc045da3cc5f4626294d884334fa807f471bb Mon Sep 17 00:00:00 2001 From: Xinyi7 Date: Sun, 25 Jan 2026 12:11:32 -0500 Subject: [PATCH] fix: add check for WriteRecordBatch (#47137) fix for https://github.com/milvus-io/milvus/issues/47073 --------- Signed-off-by: Xinyi Jiang Co-authored-by: Xinyi Jiang --- internal/storagev2/packed/packed_writer.go | 4 ++++ 1 file changed, 4 insertions(+) diff --git a/internal/storagev2/packed/packed_writer.go b/internal/storagev2/packed/packed_writer.go index 5e1c8b765e..8b6fe8cb25 100644 --- a/internal/storagev2/packed/packed_writer.go +++ b/internal/storagev2/packed/packed_writer.go @@ -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())