rt

englefly · Sep 21, 2024 · 8c688f1 · 8c688f1
1 parent 61283d9
commit 8c688f1
Showing 1 changed file with 14 additions and 12 deletions.
diff --git a/...on-test/data/nereids_rules_p0/infer_set_operator_distinct/infer_set_operator_distinct.out b/...on-test/data/nereids_rules_p0/infer_set_operator_distinct/infer_set_operator_distinct.out
@@ -201,11 +201,12 @@ PhysicalResultSink
 ------PhysicalDistribute[DistributionSpecHash]
 --------hashAgg[LOCAL]
 ----------PhysicalUnion
-------------PhysicalProject
---------------hashJoin[RIGHT_OUTER_JOIN shuffle] hashCondition=((t1.id = t2.id)) otherCondition=()
-----------------PhysicalOlapScan[t1]
-----------------PhysicalProject
-------------------PhysicalOlapScan[t2]
+------------PhysicalDistribute[DistributionSpecExecutionAny]
+--------------PhysicalProject
+----------------hashJoin[LEFT_OUTER_JOIN broadcast] hashCondition=((t1.id = t2.id)) otherCondition=()
+------------------PhysicalProject
+--------------------PhysicalOlapScan[t2]
+------------------PhysicalOlapScan[t1]
 ------------PhysicalDistribute[DistributionSpecExecutionAny]
 --------------PhysicalOlapScan[t3]
 
@@ -628,10 +629,10 @@ PhysicalResultSink
 --------------PhysicalDistribute[DistributionSpecHash]
 ----------------hashAgg[LOCAL]
 ------------------PhysicalProject
---------------------hashJoin[RIGHT_OUTER_JOIN shuffle] hashCondition=((t1.id = t2.id)) otherCondition=()
-----------------------PhysicalOlapScan[t1]
+--------------------hashJoin[LEFT_OUTER_JOIN broadcast] hashCondition=((t1.id = t2.id)) otherCondition=()
 ----------------------PhysicalProject
 ------------------------PhysicalOlapScan[t2]
+----------------------PhysicalOlapScan[t1]
 ------------PhysicalDistribute[DistributionSpecExecutionAny]
 --------------hashAgg[LOCAL]
 ----------------PhysicalOlapScan[t3]
@@ -1079,11 +1080,12 @@ PhysicalResultSink
 ------PhysicalDistribute[DistributionSpecHash]
 --------hashAgg[LOCAL]
 ----------PhysicalUnion
-------------PhysicalProject
---------------hashJoin[RIGHT_OUTER_JOIN shuffle] hashCondition=((t1.id = t2.id)) otherCondition=()
-----------------PhysicalOlapScan[t1]
-----------------PhysicalProject
-------------------PhysicalOlapScan[t2]
+------------PhysicalDistribute[DistributionSpecExecutionAny]
+--------------PhysicalProject
+----------------hashJoin[LEFT_OUTER_JOIN broadcast] hashCondition=((t1.id = t2.id)) otherCondition=()
+------------------PhysicalProject
+--------------------PhysicalOlapScan[t2]
+------------------PhysicalOlapScan[t1]
 ------------PhysicalDistribute[DistributionSpecExecutionAny]
 --------------PhysicalOlapScan[t3]