From 04f5bcd23a6c9ece1e8db799b4fd180e7813ee26 Mon Sep 17 00:00:00 2001 From: Haojun Liao Date: Tue, 11 Jul 2023 08:51:13 +0800 Subject: [PATCH] fix(stream): remove invalid set of task status . --- source/dnode/vnode/src/tq/tq.c | 6 ------ 1 file changed, 6 deletions(-) diff --git a/source/dnode/vnode/src/tq/tq.c b/source/dnode/vnode/src/tq/tq.c index 7f1f4f1538..6a08239524 100644 --- a/source/dnode/vnode/src/tq/tq.c +++ b/source/dnode/vnode/src/tq/tq.c @@ -823,12 +823,6 @@ int32_t tqExpandTask(STQ* pTq, SStreamTask* pTask, int64_t ver) { qSetTaskId(pTask->exec.pExecutor, pTask->id.taskId, pTask->id.streamId); } - if (pTask->status.taskStatus != TASK_STATUS__SCAN_HISTORY) { - tqInfo("s-task:%s status is set to %s prev in meta:%s", pTask->id.idStr, - streamGetTaskStatusStr(TASK_STATUS__SCAN_HISTORY), streamGetTaskStatusStr(pTask->status.taskStatus)); - pTask->status.taskStatus = TASK_STATUS__SCAN_HISTORY; - } - pTask->pRpcMsgList = taosArrayInit(4, sizeof(SRpcMsg)); // sink