fix: Do not replace SMJ with HJ for LeftSemi

comphead · comphead · commit ee9d917a8709 · 2025-11-04T15:00:40.000-08:00
diff --git a/spark/src/main/scala/org/apache/comet/rules/CometExecRule.scala b/spark/src/main/scala/org/apache/comet/rules/CometExecRule.scala
@@ -645,9 +645,6 @@ case class CometExecRule(session: SparkSession) extends Rule[SparkPlan] {
         normalizedPlan
       }
 
-      println(normalizedPlan)
-      println(planWithJoinRewritten)
-
       var newPlan = transform(planWithJoinRewritten)
 
       // if the plan cannot be run fully natively then explain why (when appropriate

Original file line number	Diff line number	Diff line change
`@@ -645,9 +645,6 @@ case class CometExecRule(session: SparkSession) extends Rule[SparkPlan] {`
`645`	`645`	`normalizedPlan`
`646`	`646`	`}`
`647`	`647`
`648`		`- println(normalizedPlan)`
`649`		`- println(planWithJoinRewritten)`
`650`		`-`
`651`	`648`	`var newPlan = transform(planWithJoinRewritten)`
`652`	`649`
`653`	`650`	`// if the plan cannot be run fully natively then explain why (when appropriate`