refactor(cluster): active upstream first for cluster exchange

databendlabs · Aug 22, 2023 · 60ec147 · 60ec147
1 parent f924f1b
commit 60ec147
Showing 1 changed file with 5 additions and 3 deletions.
diff --git a/src/query/service/src/api/rpc/exchange/exchange_transform_shuffle.rs b/src/query/service/src/api/rpc/exchange/exchange_transform_shuffle.rs
@@ -303,9 +303,11 @@ pub fn exchange_shuffle(params: &ShuffleExchangeParams, pipeline: &mut Pipeline)
 
     let inputs = transform.get_inputs();
     let outputs = transform.get_outputs();
-    pipeline.add_pipe(Pipe::create(inputs, outputs, vec![
-        PipeItem::create(ProcessorPtr::create(Box::new(transform)), inputs, outputs),
-    ]));
+    pipeline.add_pipe(Pipe::create(inputs, outputs, vec![PipeItem::create(
+        ProcessorPtr::create(Box::new(transform)),
+        inputs,
+        outputs,
+    )]));
 
     Ok(())
 }