Update cross_join_node.cpp

Signed-off-by: stdpain <[email protected]>
StarRocks · Oct 24, 2024 · e064902 · e064902
1 parent 47814ec
commit e064902
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/be/src/exec/cross_join_node.cpp b/be/src/exec/cross_join_node.cpp
@@ -701,7 +701,7 @@ std::vector<std::shared_ptr<pipeline::OperatorFactory>> CrossJoinNode::_decompos
         left_ops.emplace_back(std::make_shared<LimitOperatorFactory>(context->next_operator_id(), id(), limit()));
     }
 
-    if (_interpolate_passthrough && !context->is_colocate_group()) {
+    if (_interpolate_passthrough) {
         left_ops = context->maybe_interpolate_local_passthrough_exchange(runtime_state(), id(), left_ops,
                                                                          context->degree_of_parallelism(), true);
     }