Skip to content

Commit 8a8658c

Browse files
committed
Add Inner for do cartesian broadcast, SPARK-10484 point out this
1 parent f1cebae commit 8a8658c

File tree

1 file changed

+2
-1
lines changed

1 file changed

+2
-1
lines changed

sql/core/src/main/scala/org/apache/spark/sql/execution/joins/BroadcastNestedLoopJoin.scala

Lines changed: 2 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -22,7 +22,7 @@ import org.apache.spark.rdd.RDD
2222
import org.apache.spark.sql.catalyst.InternalRow
2323
import org.apache.spark.sql.catalyst.expressions._
2424
import org.apache.spark.sql.catalyst.plans.physical.Partitioning
25-
import org.apache.spark.sql.catalyst.plans.{FullOuter, JoinType, LeftOuter, RightOuter}
25+
import org.apache.spark.sql.catalyst.plans._
2626
import org.apache.spark.sql.execution.{BinaryNode, SparkPlan}
2727
import org.apache.spark.sql.execution.metric.SQLMetrics
2828
import org.apache.spark.util.collection.CompactBuffer
@@ -71,6 +71,7 @@ case class BroadcastNestedLoopJoin(
7171
left.output.map(_.withNullability(true)) ++ right.output
7272
case FullOuter =>
7373
left.output.map(_.withNullability(true)) ++ right.output.map(_.withNullability(true))
74+
case Inner => left.output ++ right.output
7475
case x =>
7576
throw new IllegalArgumentException(
7677
s"BroadcastNestedLoopJoin should not take $x as the JoinType")

0 commit comments

Comments
 (0)