From 52d7da9328f12ed197c89afd4d13be2aa30a27cf Mon Sep 17 00:00:00 2001 From: Hongze Zhang Date: Wed, 11 Sep 2024 12:33:25 +0800 Subject: [PATCH] fixup --- .../gluten/extension/columnar/rewrite/RewriteJoin.scala | 6 ++---- 1 file changed, 2 insertions(+), 4 deletions(-) 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 }