fix: fix error in indef operator filter processing

2022-07-20 21:58:03 +08:00 · 2022-07-20 21:58:03 +08:00 · 4211db2ec4
parent 33aa741979
commit 4211db2ec4
1 changed files with 1 additions and 1 deletions
--- a/source/libs/executor/src/executorimpl.c
+++ b/source/libs/executor/src/executorimpl.c
@ -3957,7 +3957,7 @@ static SSDataBlock* doApplyIndefinitFunction(SOperatorInfo* pOperator) {

    doFilter(pIndefInfo->pCondition, pInfo->pRes);
    size_t rows = pInfo->pRes->info.rows;
-    if (rows >= 0) {
+    if (rows > 0 || pOperator->status == OP_EXEC_DONE) {
      break;
    }
  }