We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
1 parent 41c52d2 commit 72c5c0bCopy full SHA for 72c5c0b
1 file changed
src/query/storages/fuse/src/operations/read/parquet_rows_fetcher.rs
@@ -185,6 +185,7 @@ impl RowsFetcher for ParquetRowsFetcher {
185
if blocks_bytes >= 50 * 1024 * 1024 || tasks_indices.peek().is_none() {
186
let tasks_handle = std::mem::take(&mut tasks_handle);
187
let tasks_block = future::try_join_all(tasks_handle).await.unwrap();
188
+ blocks_bytes = 0;
189
for task_block in tasks_block {
190
let (final_index, block) = task_block?;
191
final_blocks.insert(final_index, block);
0 commit comments