diff --git a/source/libs/executor/src/scanoperator.c b/source/libs/executor/src/scanoperator.c
index 15fc164cf1..42c0b88089 100644
--- 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;
 }