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())