diff --git a/gluten-core/src/main/scala/io/glutenproject/extension/columnar/TransformHintRule.scala b/gluten-core/src/main/scala/io/glutenproject/extension/columnar/TransformHintRule.scala index 1431af2dda34d..d76b64349d70f 100644 --- a/gluten-core/src/main/scala/io/glutenproject/extension/columnar/TransformHintRule.scala +++ b/gluten-core/src/main/scala/io/glutenproject/extension/columnar/TransformHintRule.scala @@ -191,7 +191,6 @@ case class FallbackMultiCodegens(session: SparkSession) extends Rule[SparkPlan] case p: ShuffledHashJoinExec => tagNotTransformable(p.withNewChildren(p.children.map(tagNotTransformableRecursive))) case p if !supportCodegen(p) => - // insert row guard them recursively p.withNewChildren(p.children.map(tagNotTransformableForMultiCodegens)) case p if isAQEShuffleReadExec(p) => p.withNewChildren(p.children.map(tagNotTransformableForMultiCodegens))