Fix

apache · Sep 9, 2024 · 23cb69a · 23cb69a
1 parent a52aecb
commit 23cb69a
Showing 1 changed file with 3 additions and 3 deletions.
diff --git a/...t/src/main/scala/org/apache/gluten/execution/BroadcastNestedLoopJoinExecTransformer.scala b/...t/src/main/scala/org/apache/gluten/execution/BroadcastNestedLoopJoinExecTransformer.scala
@@ -96,6 +96,7 @@ abstract class BroadcastNestedLoopJoinExecTransformer(
       joinType match {
         case _: InnerLike => right.outputPartitioning
         case RightOuter => right.outputPartitioning
+        case LeftOuter => left.outputPartitioning
         case x =>
           throw new IllegalArgumentException(
             s"BroadcastNestedLoopJoin should not take $x as the JoinType with building left side")
@@ -104,6 +105,7 @@ abstract class BroadcastNestedLoopJoinExecTransformer(
       joinType match {
         case _: InnerLike => left.outputPartitioning
         case LeftOuter => left.outputPartitioning
+        case RightOuter => right.outputPartitioning
         case x =>
           throw new IllegalArgumentException(
             s"BroadcastNestedLoopJoin should not take $x as the JoinType with building right side")
@@ -123,9 +125,7 @@ abstract class BroadcastNestedLoopJoinExecTransformer(
 
     val operatorId = context.nextOperatorId(this.nodeName)
     val joinParams = new JoinParams
-    if (condition.isDefined) {
-      joinParams.isWithCondition = true
-    }
+    joinParams.isWithCondition = condition.isDefined
 
     val crossRel = JoinUtils.createCrossRel(
       substraitJoinType,