From 082882b71ecfad70496a7d6ab7373150d57cc749 Mon Sep 17 00:00:00 2001
From: Haojun Liao <hjliao@taosdata.com>
Date: Mon, 21 Aug 2023 19:29:03 +0800
Subject: [PATCH] fix(stream): reset the upstream stage info.

---
 source/libs/stream/src/streamMeta.c | 1 +
 1 file changed, 1 insertion(+)

diff --git a/source/libs/stream/src/streamMeta.c b/source/libs/stream/src/streamMeta.c
index 979b9be384..11574e6d70 100644
--- a/source/libs/stream/src/streamMeta.c
+++ b/source/libs/stream/src/streamMeta.c
@@ -538,6 +538,7 @@ int32_t streamLoadTasks(SStreamMeta* pMeta) {
       continue;
     }
 
+    streamTaskResetUpstreamStageInfo(pTask);
     if (taosHashPut(pMeta->pTasks, keys, sizeof(keys), &pTask, sizeof(void*)) < 0) {
       doClear(pKey, pVal, pCur, pRecycleList);
       tFreeStreamTask(pTask);