fix: performance degrade

databendlabs · Oct 31, 2024 · 828787e · 828787e
1 parent 3214c8a
commit 828787e
Show file tree

Hide file tree

Showing 2 changed files with 4 additions and 3 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
@@ -212,14 +212,14 @@ pub fn build_fuse_parquet_source_pipeline(
 
             match is_lazy {
                 true => {
-                    let (pipe, source_senders) = build_lazy_source(max_threads, ctx.clone())?;
+                    let (pipe, source_senders) = build_lazy_source(max_io_requests, ctx.clone())?;
                     senders.extend(source_senders);
                     pipeline.add_pipe(pipe);
                 }
                 false => {
                     let batch_size = ctx.get_settings().get_storage_fetch_part_num()? as usize;
                     let pipe = build_block_source(
-                        max_threads,
+                        max_io_requests,
                         partitions.clone(),
                         batch_size,
                         ctx.clone(),

diff --git a/tests/sqllogictests/suites/mode/standalone/explain_native/explain_pipeline.test b/tests/sqllogictests/suites/mode/standalone/explain_native/explain_pipeline.test
@@ -17,7 +17,8 @@ explain pipeline select a from t1 ignore_result
 ----
 EmptySink × 1
   NativeDeserializeDataTransform × 1
-    SyncReadNativeDataSource × 1
+    SyncReadNativeDataTransform × 1
+      BlockPartitionSource × 1
 
 
 statement ok