提交 04f5bcd2 编写于 作者: H Haojun Liao

fix(stream): remove invalid set of task status .

上级 8a6a876f
......@@ -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
......
Markdown is supported
0% .
You are about to add 0 people to the discussion. Proceed with caution.
先完成此消息的编辑!
想要评论请 注册