diff --git a/source/libs/stream/src/streamExec.c b/source/libs/stream/src/streamExec.c
index 1a786077709b84b2c12739c947f823b822efe0a3..aa2c8050deb5ea6a3c79f26c0e83f7de37d2aa6a 100644
--- a/source/libs/stream/src/streamExec.c
+++ b/source/libs/stream/src/streamExec.c
@@ -84,7 +84,7 @@ static int32_t streamTaskExecImpl(SStreamTask* pTask, SStreamQueueItem* pItem, i
     }
 
     if (streamTaskShouldStop(&pTask->status)) {
-      taosArrayDestroy(pRes);  // memory leak
+      taosArrayDestroyEx(pRes, (FDelete)blockDataFreeRes);
       return 0;
     }