fix(stream): fix mgmt add new calc reader task (#34358)

JinqingKuang · web-flow · commit 7901e3e2d553 · 2026-01-22T09:41:29.000+08:00
diff --git a/source/dnode/mnode/impl/src/mndStreamMgmt.c b/source/dnode/mnode/impl/src/mndStreamMgmt.c
@@ -3584,6 +3584,9 @@ int32_t msmWatchRecordNewTask(SStmGrpCtx* pCtx, SStmTaskStatusMsg* pTask) {
         TSDB_CHECK_NULL(pNewTask, code, lino, _exit, terrno);
       } else {
         TAOS_CHECK_EXIT(tdListAppend(pStatus->calcReaders, &taskStatus));
+        SListNode* pTailNode = tdListGetTail(pStatus->calcReaders);
+        QUERY_CHECK_NULL(pTailNode, code, lino, _exit, TSDB_CODE_INTERNAL_ERROR);
+        pNewTask = (SStmTaskStatus*)pTailNode->data;
       }
       
       TAOS_CHECK_EXIT(msmSTAddToTaskMap(pCtx, streamId, NULL, NULL, pNewTask));

Original file line number	Diff line number	Diff line change
`@@ -3584,6 +3584,9 @@ int32_t msmWatchRecordNewTask(SStmGrpCtx* pCtx, SStmTaskStatusMsg* pTask) {`
`3584`	`3584`	`TSDB_CHECK_NULL(pNewTask, code, lino, _exit, terrno);`
`3585`	`3585`	`} else {`
`3586`	`3586`	`TAOS_CHECK_EXIT(tdListAppend(pStatus->calcReaders, &taskStatus));`
	`3587`	`+ SListNode* pTailNode = tdListGetTail(pStatus->calcReaders);`
	`3588`	`+ QUERY_CHECK_NULL(pTailNode, code, lino, _exit, TSDB_CODE_INTERNAL_ERROR);`
	`3589`	`+ pNewTask = (SStmTaskStatus*)pTailNode->data;`
`3587`	`3590`	`}`
`3588`	`3591`
`3589`	`3592`	`TAOS_CHECK_EXIT(msmSTAddToTaskMap(pCtx, streamId, NULL, NULL, pNewTask));`