fix(processor): try fix test failure

databendlabs · Sep 30, 2022 · 5acc981 · 5acc981
1 parent 2e7b397
commit 5acc981
Show file tree

Hide file tree

Showing 2 changed files with 2 additions and 1 deletion.
diff --git a/src/query/service/src/api/rpc/exchange/exchange_manager.rs b/src/query/service/src/api/rpc/exchange/exchange_manager.rs
@@ -668,6 +668,7 @@ impl FragmentCoordinator {
 
             match &self.payload {
                 FragmentPayload::PlanV2(plan) => {
+                    let ctx = QueryContext::create_from(ctx);
                     let pipeline_builder = PipelineBuilderV2::create(ctx);
                     self.pipeline_build_res = Some(pipeline_builder.finalize(plan)?);
                 }

diff --git a/src/query/service/src/sql/executor/pipeline_builder.rs b/src/query/service/src/sql/executor/pipeline_builder.rs
@@ -90,9 +90,9 @@ pub struct PipelineBuilder {
 impl PipelineBuilder {
     pub fn create(ctx: Arc<QueryContext>) -> PipelineBuilder {
         PipelineBuilder {
+            ctx,
             pipelines: vec![],
             main_pipeline: Pipeline::create(),
-            ctx: QueryContext::create_from(ctx),
         }
     }