mark_joins_needing_dedupe_incompatible

coderfender · coderfender · commit 242c8b845127 · 2026-05-29T11:37:30.000-07:00
diff --git a/spark/src/main/scala/org/apache/spark/sql/comet/operators.scala b/spark/src/main/scala/org/apache/spark/sql/comet/operators.scala
@@ -1957,8 +1957,6 @@ object CometBroadcastNestedLoopJoinExec extends CometOperatorSerde[BroadcastNest
       case _                        => Compatible(None)
     }
 
-  override def getUnsupportedReasons(): Seq[String] = Seq(unmatchedDuplicationReason)
-
   /**
    * Convert a Spark operator into a protocol buffer representation that can be passed into native
    * code.

Original file line number	Diff line number	Diff line change
`@@ -1957,8 +1957,6 @@ object CometBroadcastNestedLoopJoinExec extends CometOperatorSerde[BroadcastNest`
`1957`	`1957`	`case _ => Compatible(None)`
`1958`	`1958`	`}`
`1959`	`1959`
`1960`		`- override def getUnsupportedReasons(): Seq[String] = Seq(unmatchedDuplicationReason)`
`1961`		`-`
`1962`	`1960`	`/**`
`1963`	`1961`	`* Convert a Spark operator into a protocol buffer representation that can be passed into native`
`1964`	`1962`	`* code.`