We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
There was an error while loading. Please reload this page.
1 parent b6a99f1 commit 7bff6d0Copy full SHA for 7bff6d0
src/query/pipeline/sources/src/processors/sources/input_formats/input_format_text.rs
@@ -197,11 +197,11 @@ impl<T: InputFormatTextBase> AligningState<T> {
197
rows.push(i + 1 + size_last_remain)
198
}
199
200
- let batch_end = rows[rows.len() - 1] - size_last_remain;
201
if rows.is_empty() {
202
self.tail_of_last_batch.extend_from_slice(buf);
203
vec![]
204
} else {
+ let batch_end = rows[rows.len() - 1] - size_last_remain;
205
output.data = mem::take(&mut self.tail_of_last_batch);
206
output.data.extend_from_slice(&buf[..batch_end]);
207
self.tail_of_last_batch.extend_from_slice(&buf[batch_end..]);
0 commit comments