diff --git a/sql/catalyst/src/main/scala/org/apache/spark/sql/catalyst/optimizer/joins.scala b/sql/catalyst/src/main/scala/org/apache/spark/sql/catalyst/optimizer/joins.scala index 5fb30e810649b..44875bfb3ec22 100644 --- a/sql/catalyst/src/main/scala/org/apache/spark/sql/catalyst/optimizer/joins.scala +++ b/sql/catalyst/src/main/scala/org/apache/spark/sql/catalyst/optimizer/joins.scala @@ -304,8 +304,8 @@ trait JoinSelectionHelper extends Logging { canBroadcastBySize(join.right, conf) && !hintToNotBroadcastRight(join.hint) } getBuildSide( - canBuildBroadcastLeft(join.joinType) && buildLeft, - canBuildBroadcastRight(join.joinType) && buildRight, + buildLeft && canBuildBroadcastLeft(join.joinType), + buildRight && canBuildBroadcastRight(join.joinType), join.left, join.right ) @@ -332,8 +332,8 @@ trait JoinSelectionHelper extends Logging { forceApplyShuffledHashJoin(conf) } getBuildSide( - canBuildShuffledHashJoinLeft(join.joinType) && buildLeft, - canBuildShuffledHashJoinRight(join.joinType) && buildRight, + buildLeft && canBuildShuffledHashJoinLeft(join.joinType), + buildRight && canBuildShuffledHashJoinRight(join.joinType), join.left, join.right )