fix: clean up block data to use it again as result data block in doApplyIndefinitFunction

2022-07-21 09:43:06 +08:00 · 2022-07-21 09:43:06 +08:00 · 3828954f15
parent b905133faf
commit 3828954f15
1 changed files with 2 additions and 0 deletions
--- a/source/libs/executor/src/executorimpl.c
+++ b/source/libs/executor/src/executorimpl.c
@ -3959,6 +3959,8 @@ static SSDataBlock* doApplyIndefinitFunction(SOperatorInfo* pOperator) {
    size_t rows = pInfo->pRes->info.rows;
    if (rows > 0 || pOperator->status == OP_EXEC_DONE) {
      break;
+    } else {
+      blockDataCleanup(pInfo->pRes);
    }
  }