Skip to content

Commit eb3fe00

Browse files
author
Bhargava Vadlamani
committed
mark_joins_needing_dedupe_incompatible
1 parent 242c8b8 commit eb3fe00

1 file changed

Lines changed: 3 additions & 3 deletions

File tree

spark/src/main/scala/org/apache/spark/sql/comet/operators.scala

Lines changed: 3 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -1951,10 +1951,10 @@ object CometBroadcastNestedLoopJoinExec extends CometOperatorSerde[BroadcastNest
19511951

19521952
override def getSupportLevel(op: BroadcastNestedLoopJoinExec): SupportLevel =
19531953
(op.joinType, op.buildSide) match {
1954-
case (LeftOuter, BuildLeft) => Unsupported(Some(unmatchedDuplicationReason))
1954+
case (LeftOuter, BuildLeft) => Unsupported(Some(unmatchedDuplicationReason))
19551955
case (RightOuter, BuildRight) => Unsupported(Some(unmatchedDuplicationReason))
1956-
case (FullOuter, _) => Unsupported(Some(unmatchedDuplicationReason))
1957-
case _ => Compatible(None)
1956+
case (FullOuter, _) => Unsupported(Some(unmatchedDuplicationReason))
1957+
case _ => Compatible(None)
19581958
}
19591959

19601960
/**

0 commit comments

Comments
 (0)