From 586651e3c8be714cf37de2481aba46da5922d11e Mon Sep 17 00:00:00 2001 From: PHILO-HE Date: Fri, 6 Sep 2024 17:45:24 +0800 Subject: [PATCH] Initial --- .../BroadcastNestedLoopJoinExecTransformer.scala | 12 +----------- 1 file changed, 1 insertion(+), 11 deletions(-) diff --git a/gluten-substrait/src/main/scala/org/apache/gluten/execution/BroadcastNestedLoopJoinExecTransformer.scala b/gluten-substrait/src/main/scala/org/apache/gluten/execution/BroadcastNestedLoopJoinExecTransformer.scala index ae407b3b3efa1..f76cca3fe7440 100644 --- a/gluten-substrait/src/main/scala/org/apache/gluten/execution/BroadcastNestedLoopJoinExecTransformer.scala +++ b/gluten-substrait/src/main/scala/org/apache/gluten/execution/BroadcastNestedLoopJoinExecTransformer.scala @@ -162,21 +162,11 @@ abstract class BroadcastNestedLoopJoinExecTransformer( } def validateJoinTypeAndBuildSide(): ValidationResult = { - val result = joinType match { + joinType match { case _: InnerLike | LeftOuter | RightOuter => ValidationResult.succeeded case _ => ValidationResult.failed(s"$joinType join is not supported with BroadcastNestedLoopJoin") } - - if (!result.ok()) { - return result - } - - (joinType, buildSide) match { - case (LeftOuter, BuildLeft) | (RightOuter, BuildRight) => - ValidationResult.failed(s"$joinType join is not supported with $buildSide") - case _ => ValidationResult.succeeded // continue - } } override protected def doValidateInternal(): ValidationResult = {