diff --git a/src/query/storages/fuse/src/operations/read/fuse_source.rs b/src/query/storages/fuse/src/operations/read/fuse_source.rs
index 728a0a4129bd9..cbf12f39c5d75 100644
--- 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(