diff --git a/source/libs/executor/src/scanoperator.c b/source/libs/executor/src/scanoperator.c
index 2348d67434..e787e73434 100644
--- a/source/libs/executor/src/scanoperator.c
+++ b/source/libs/executor/src/scanoperator.c
@@ -2364,6 +2364,8 @@ void streamScanReloadState(SOperatorInfo* pOperator) {
       pUpInfo->pMap = NULL;
       pInfo->stateStore.updateInfoDestroy(pUpInfo);
     }
+  } else {
+    pInfo->stateStore.updateInfoDestroy(pUpInfo);
   }
 }