tweak

databendlabs · Sep 23, 2023 · c8248a5 · c8248a5
1 parent 2036ddc
commit c8248a5
Showing 1 changed file with 5 additions and 2 deletions.
diff --git a/src/query/storages/fuse/src/operations/read/fuse_source.rs b/src/query/storages/fuse/src/operations/read/fuse_source.rs
@@ -190,7 +190,8 @@ pub fn build_fuse_parquet_source_pipeline(
                 );
             }
             pipeline.add_pipe(source_builder.finalize());
-            pipeline.try_resize(std::cmp::min(max_threads, max_io_requests))?;
+            // pipeline.try_resize(std::cmp::min(max_threads, max_io_requests))?;
+            pipeline.try_resize(max_threads)?;
 
             info!(
                 "read block pipeline resize from:{} to:{}",
@@ -210,7 +211,9 @@ pub fn build_fuse_parquet_source_pipeline(
             index_reader.clone(),
             virtual_reader.clone(),
         )
-    })
+    });
+
+    pipeline.try_resize(max_threads)
 }
 
 pub fn dispatch_partitions(