diff --git a/fe/fe-core/src/main/java/org/apache/doris/planner/DistributedPlanner.java b/fe/fe-core/src/main/java/org/apache/doris/planner/DistributedPlanner.java index efaa5c1d8c7287..16caf11d2d2751 100644 --- a/fe/fe-core/src/main/java/org/apache/doris/planner/DistributedPlanner.java +++ b/fe/fe-core/src/main/java/org/apache/doris/planner/DistributedPlanner.java @@ -545,7 +545,7 @@ private boolean canBucketShuffleJoin(HashJoinNode node, PlanNode leftRoot, OlapScanNode leftScanNode = ((OlapScanNode) leftRoot); //1 the left table must be only one partition - if (leftScanNode.getSelectedPartitionIds().size() > 1) { + if (leftScanNode.getSelectedPartitionIds().size() != 1) { return false; }