diff --git a/source/libs/stream/src/streamExec.c b/source/libs/stream/src/streamExec.c
index b325a8a961..2f019529e4 100644
--- a/source/libs/stream/src/streamExec.c
+++ b/source/libs/stream/src/streamExec.c
@@ -146,6 +146,7 @@ static int32_t streamTaskExecImpl(SStreamTask* pTask, SStreamQueueItem* pItem, i
         return code;
       }
 
+      pRes = NULL;
       size = 0;
       numOfBlocks = 0;
     }