diff --git a/internal/core/src/segcore/SegmentChunkReader.h b/internal/core/src/segcore/SegmentChunkReader.h index 9c662e9318..2bff2ae4ea 100644 --- a/internal/core/src/segcore/SegmentChunkReader.h +++ b/internal/core/src/segcore/SegmentChunkReader.h @@ -84,6 +84,7 @@ class SegmentChunkReader { if (++processed_rows >= batch_size) { current_chunk_id = chunk_id; current_chunk_pos = i + 1; + break; } } } @@ -108,6 +109,7 @@ class SegmentChunkReader { if (++processed_rows >= batch_size) { current_chunk_id = chunk_id; current_chunk_pos = i + 1; + break; } } }