diff --git a/gluten-substrait/src/main/scala/org/apache/gluten/extension/columnar/rewrite/RewriteJoin.scala b/gluten-substrait/src/main/scala/org/apache/gluten/extension/columnar/rewrite/RewriteJoin.scala index b97ac0b06d6c..6f019452e6c0 100644 --- a/gluten-substrait/src/main/scala/org/apache/gluten/extension/columnar/rewrite/RewriteJoin.scala +++ b/gluten-substrait/src/main/scala/org/apache/gluten/extension/columnar/rewrite/RewriteJoin.scala @@ -28,10 +28,8 @@ import org.apache.spark.sql.execution.joins.{ShuffledHashJoinExec, SortMergeJoin /** If force ShuffledHashJoin, convert [[SortMergeJoinExec]] to [[ShuffledHashJoinExec]]. */ object RewriteJoin extends RewriteSingleNode with JoinSelectionHelper { private def getSmjBuildSide(join: SortMergeJoinExec): Option[BuildSide] = { - val leftBuildable = - BackendsApiManager.getSettings.supportHashBuildJoinTypeOnLeft(join.joinType) - val rightBuildable = - BackendsApiManager.getSettings.supportHashBuildJoinTypeOnRight(join.joinType) + val leftBuildable = canBuildShuffledHashJoinLeft(join.joinType) + val rightBuildable = canBuildShuffledHashJoinRight(join.joinType) if (!leftBuildable && !rightBuildable) { return None }