fix: destory data block to fix oom

2023-06-18 06:50:53 +08:00 · 2023-06-18 06:50:53 +08:00 · 9e781ed7a6
parent 577c131360
commit 9e781ed7a6
1 changed files with 2 additions and 1 deletions
--- a/source/libs/executor/src/scanoperator.c
+++ b/source/libs/executor/src/scanoperator.c
@ -2728,7 +2728,8 @@ static SSDataBlock* getTableDataBlockImpl(void* param) {
  pAPI->tsdReader.tsdReaderClose(source->dataReader);
  source->dataReader = NULL;
  pInfo->base.dataReader = NULL;
-
+  blockDataDestroy(source->inputBlock);
+  source->inputBlock = NULL;
  return NULL;
 }