Skip to content

Commit 6af292c

Browse files
JkSelfzhouyuan
authored andcommitted
Fix smj q14a perf
1 parent 10728fd commit 6af292c

File tree

1 file changed

+8
-0
lines changed

1 file changed

+8
-0
lines changed

velox/exec/MergeJoin.cpp

Lines changed: 8 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -627,6 +627,10 @@ bool MergeJoin::addToOutputForLeftJoin() {
627627
}
628628
addOutputRow(left, i, right, j);
629629
}
630+
631+
if (isLeftSemiFilterJoin(joinType_) && !filter_) {
632+
break;
633+
}
630634
}
631635
}
632636
}
@@ -710,6 +714,10 @@ bool MergeJoin::addToOutputForRightJoin() {
710714
addOutputRow(left, j, right, i);
711715
}
712716
}
717+
718+
if (isRightSemiFilterJoin(joinType_) && !filter_) {
719+
break;
720+
}
713721
}
714722
}
715723
}

0 commit comments

Comments
 (0)