diff --git a/backends-clickhouse/src/main/scala/org/apache/gluten/execution/CHHashJoinExecTransformer.scala b/backends-clickhouse/src/main/scala/org/apache/gluten/execution/CHHashJoinExecTransformer.scala index 2dd45281e4169..cb240a55f76c2 100644 --- a/backends-clickhouse/src/main/scala/org/apache/gluten/execution/CHHashJoinExecTransformer.scala +++ b/backends-clickhouse/src/main/scala/org/apache/gluten/execution/CHHashJoinExecTransformer.scala @@ -70,7 +70,7 @@ object JoinTypeTransform { if (!buildRight) { throw new IllegalArgumentException("LeftAnti join should not switch children") } - JoinRel.JoinType.JOIN_TYPE_ANTI + JoinRel.JoinType.JOIN_TYPE_LEFT_ANTI case _ => // TODO: Support cross join with Cross Rel JoinRel.JoinType.UNRECOGNIZED diff --git a/backends-velox/src/main/scala/org/apache/gluten/execution/ShuffledHashJoinExecTransformer.scala b/backends-velox/src/main/scala/org/apache/gluten/execution/ShuffledHashJoinExecTransformer.scala index d78e6c5b3e538..e3c93848dc2b6 100644 --- a/backends-velox/src/main/scala/org/apache/gluten/execution/ShuffledHashJoinExecTransformer.scala +++ b/backends-velox/src/main/scala/org/apache/gluten/execution/ShuffledHashJoinExecTransformer.scala @@ -69,7 +69,7 @@ case class ShuffledHashJoinExecTransformer( JoinRel.JoinType.JOIN_TYPE_LEFT_SEMI } case LeftAnti => - JoinRel.JoinType.JOIN_TYPE_ANTI + JoinRel.JoinType.JOIN_TYPE_LEFT_ANTI case _ => JoinRel.JoinType.UNRECOGNIZED } @@ -112,7 +112,7 @@ case class BroadcastHashJoinExecTransformer( case LeftSemi | ExistenceJoin(_) => JoinRel.JoinType.JOIN_TYPE_LEFT_SEMI case LeftAnti => - JoinRel.JoinType.JOIN_TYPE_ANTI + JoinRel.JoinType.JOIN_TYPE_LEFT_ANTI case _ => // TODO: Support cross join with Cross Rel JoinRel.JoinType.UNRECOGNIZED diff --git a/cpp-ch/local-engine/Common/CHUtil.cpp b/cpp-ch/local-engine/Common/CHUtil.cpp index 9558bf957d4a5..3a36fa929104f 100644 --- a/cpp-ch/local-engine/Common/CHUtil.cpp +++ b/cpp-ch/local-engine/Common/CHUtil.cpp @@ -1110,7 +1110,7 @@ JoinUtil::getJoinKindAndStrictness(substrait::JoinRel_JoinType join_type, bool i return {DB::JoinKind::Left, DB::JoinStrictness::Any}; return {DB::JoinKind::Left, DB::JoinStrictness::Semi}; } - case substrait::JoinRel_JoinType_JOIN_TYPE_ANTI: + case substrait::JoinRel_JoinType_JOIN_TYPE_LEFT_ANTI: return {DB::JoinKind::Left, DB::JoinStrictness::Anti}; case substrait::JoinRel_JoinType_JOIN_TYPE_LEFT: return {DB::JoinKind::Left, DB::JoinStrictness::All};