Skip to content

Commit 5522720

Browse files
committed
remove unnecessary code
1 parent 1ed00e1 commit 5522720

File tree

1 file changed

+0
-5
lines changed

1 file changed

+0
-5
lines changed

spark/src/main/scala/org/apache/comet/serde/QueryPlanSerde.scala

Lines changed: 0 additions & 5 deletions
Original file line numberDiff line numberDiff line change
@@ -2865,11 +2865,6 @@ object QueryPlanSerde extends Logging with ShimQueryPlanSerde with CometExprShim
28652865
case RightOuter => JoinType.RightOuter
28662866
case FullOuter => JoinType.FullOuter
28672867
case LeftSemi => JoinType.LeftSemi
2868-
// TODO: DF SMJ with join condition fails TPCH q21
2869-
case LeftAnti if condition.isEmpty => JoinType.LeftAnti
2870-
case LeftAnti =>
2871-
withInfo(join, "LeftAnti SMJ join with condition is not supported")
2872-
return None
28732868
case _ =>
28742869
// Spark doesn't support other join types
28752870
withInfo(op, s"Unsupported join type ${join.joinType}")

0 commit comments

Comments
 (0)