Skip to content

Commit 021ef2d

Browse files
committed
fix: Do not replace SMJ with HJ for LeftSemi
1 parent ee9d917 commit 021ef2d

File tree

1 file changed

+1
-1
lines changed

1 file changed

+1
-1
lines changed

spark/src/main/scala/org/apache/comet/rules/RewriteJoin.scala

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -70,7 +70,7 @@ object RewriteJoin extends JoinSelectionHelper {
7070
case Some(BuildRight) if smj.joinType == LeftAnti || smj.joinType == LeftSemi =>
7171
withInfo(
7272
smj,
73-
"Cannot rewrite SortMergeJoin to HashJoin: BuildRight with LeftSemi/LeftAnti is not supported")
73+
s"Cannot rewrite SortMergeJoin to HashJoin: BuildRight with ${smj.joinType} is not supported")
7474
// LeftAnti https://github.com/apache/datafusion-comet/issues/457
7575
// LeftSemi https://github.com/apache/datafusion-comet/issues/2667
7676
plan

0 commit comments

Comments
 (0)