File tree Expand file tree Collapse file tree 1 file changed +1
-2
lines changed Expand file tree Collapse file tree 1 file changed +1
-2
lines changed Original file line number Diff line number Diff line change @@ -517,8 +517,6 @@ class TColumnShardPayloadSerializer : public IPayloadSerializer {
517
517
i64 nextRowSize = rowCalculator.GetRowBytesSize (index);
518
518
519
519
if (toPrepareSize + nextRowSize >= (i64 )ColumnShardMaxOperationBytes) {
520
- AFL_ENSURE (index > 0 );
521
-
522
520
toPrepare.push_back (batch->Slice (0 , index));
523
521
unpreparedBatch.Batches .push_front (batch->Slice (index, batch->num_rows () - index));
524
522
@@ -541,6 +539,7 @@ class TColumnShardPayloadSerializer : public IPayloadSerializer {
541
539
toPrepare.push_back (batch);
542
540
}
543
541
542
+ AFL_ENSURE (!toPrepare.empty () && toPrepare.front ()->num_rows () > 0 );
544
543
auto batch = MakeIntrusive<TColumnBatch>(NArrow::CombineBatches (toPrepare), Alloc);
545
544
Batches[shardId].emplace_back (batch);
546
545
Memory += batch->GetMemory ();
You can’t perform that action at this time.
0 commit comments