From 5acc981ad3733233507cb252e9a0a6302e4d63bb Mon Sep 17 00:00:00 2001
From: zhang2014 <coswde@gmail.com>
Date: Fri, 30 Sep 2022 16:06:59 +0800
Subject: [PATCH] fix(processor): try fix test failure

---
 src/query/service/src/api/rpc/exchange/exchange_manager.rs | 1 +
 src/query/service/src/sql/executor/pipeline_builder.rs     | 2 +-
 2 files changed, 2 insertions(+), 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
index 5b217033aca8..604f78558fe2 100644
--- 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
index 35e0aa482543..67fe9066d584 100644
--- 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),
         }
     }