diff --git a/source/libs/stream/src/streamExec.c b/source/libs/stream/src/streamExec.c
index 9dd59ec112f06da30dca3006576a82516a5cc919..5f9aec4db0c51e0e15d9cc96c6965d81255b8cb3 100644
--- a/source/libs/stream/src/streamExec.c
+++ b/source/libs/stream/src/streamExec.c
@@ -202,6 +202,7 @@ int32_t streamScanExec(SStreamTask* pTask, int32_t batchSz) {
     qRes->blocks = pRes;
     code = streamTaskOutput(pTask, qRes);
     if (code == TSDB_CODE_UTIL_QUEUE_OUT_OF_MEMORY) {
+      taosArrayDestroyEx(pRes, (FDelete)blockDataFreeRes);
       taosFreeQitem(qRes);
       return code;
     }