Make input_ == nullptr to make sure the needsInput() return true

facebookincubator · Aug 6, 2024 · d8e1295 · d8e1295
1 parent 6ac851e
commit d8e1295
Showing 1 changed file with 1 addition and 0 deletions.
diff --git a/velox/exec/MergeJoin.cpp b/velox/exec/MergeJoin.cpp
@@ -626,6 +626,7 @@ RowVectorPtr MergeJoin::filterOutputForAntiJoin(const RowVectorPtr& output) {
 
   if (numPassed == 0) {
     // No rows passed.
+    input_ = nullptr;
     return nullptr;
   }