提交 87c7e4c0 编写于 作者: H Haojun Liao

fix(stream): not launch stream tasks when restarting the stream tasks.

上级 e984affe
...@@ -1180,6 +1180,8 @@ int32_t tqProcessTaskDeployReq(STQ* pTq, int64_t sversion, char* msg, int32_t ms ...@@ -1180,6 +1180,8 @@ int32_t tqProcessTaskDeployReq(STQ* pTq, int64_t sversion, char* msg, int32_t ms
if (p != NULL) { if (p != NULL) {
streamMetaReleaseTask(pStreamMeta, p); streamMetaReleaseTask(pStreamMeta, p);
} }
} else {
tqDebug("vgId:%d not leader, not launch stream task s-task:0x%x", vgId, taskId);
} }
} else { } else {
tqWarn("vgId:%d failed to add s-task:0x%x, since already exists in meta store", vgId, taskId); tqWarn("vgId:%d failed to add s-task:0x%x, since already exists in meta store", vgId, taskId);
......
...@@ -495,7 +495,10 @@ int32_t streamTaskRestart(SStreamTask* pTask, const char* pDir, bool startTask) ...@@ -495,7 +495,10 @@ int32_t streamTaskRestart(SStreamTask* pTask, const char* pDir, bool startTask)
pTask->status.stage, streamGetTaskStatusStr(pTask->status.taskStatus)); pTask->status.stage, streamGetTaskStatusStr(pTask->status.taskStatus));
// 3. start to check the downstream status // 3. start to check the downstream status
streamTaskCheckDownstreamTasks(pTask); if (startTask) {
streamTaskCheckDownstreamTasks(pTask);
}
return 0; return 0;
} }
......
Markdown is supported
0% .
You are about to add 0 people to the discussion. Proceed with caution.
先完成此消息的编辑!
想要评论请 注册