fix(stream): reset the upstream stage info.

082882b7 · Haojun Liao · 8b27f98e · 082882b7
显示空白变更内容
内联并排

Showing with 1 addition and 0 deletion

source/libs/stream/src/streamMeta.c source/libs/stream/src/streamMeta.c +1 -0

未找到文件。
--- 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);