tweak

dantengsky · dantengsky · commit c8248a5566a4 · 2023-09-23T17:35:37.000+08:00
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(

Original file line number	Diff line number	Diff line change
`@@ -190,7 +190,8 @@ pub fn build_fuse_parquet_source_pipeline(`
`190`	`190`	`);`
`191`	`191`	`}`
`192`	`192`	`pipeline.add_pipe(source_builder.finalize());`
`193`		`- pipeline.try_resize(std::cmp::min(max_threads, max_io_requests))?;`
	`193`	`+ // pipeline.try_resize(std::cmp::min(max_threads, max_io_requests))?;`
	`194`	`+ pipeline.try_resize(max_threads)?;`
`194`	`195`
`195`	`196`	`info!(`
`196`	`197`	`"read block pipeline resize from:{} to:{}",`
`@@ -210,7 +211,9 @@ pub fn build_fuse_parquet_source_pipeline(`
`210`	`211`	`index_reader.clone(),`
`211`	`212`	`virtual_reader.clone(),`
`212`	`213`	`)`
`213`		`- })`
	`214`	`+ });`
	`215`	`+`
	`216`	`+ pipeline.try_resize(max_threads)`
`214`	`217`	`}`
`215`	`218`
`216`	`219`	`pub fn dispatch_partitions(`