Fix the SortBuffer's noMoreInput called twice in Left Anti join

facebookincubator · Aug 8, 2024 · 04f6fab · 04f6fab
1 parent ad1f393
commit 04f6fab
Showing 1 changed file with 7 additions and 1 deletion.
diff --git a/velox/exec/MergeJoin.cpp b/velox/exec/MergeJoin.cpp
@@ -646,7 +646,13 @@ RowVectorPtr MergeJoin::getOutput() {
         // No rows survived the filter. Get more rows.
         continue;
       } else if (isAntiJoin(joinType_)) {
-        return filterOutputForAntiJoin(output);
+        output = filterOutputForAntiJoin(output);
+        if (output) {
+          return output;
+        }
+
+        // No rows survived the filter for anti join. Get more rows.
+        continue;
       } else {
         return output;
       }