提交 57ef43ba 编写于 作者: H Haojun Liao

fix(stream): set sink task status to enable the checkpoint.

上级 ab949010
......@@ -445,8 +445,11 @@ int32_t streamProcessScanHistoryFinishReq(SStreamTask* pTask, SStreamScanHistory
streamNotifyUpstreamContinue(pTask);
// mnode will not send the pause/resume message to the sink task, so no need to enable the pause for sink tasks.
if (pTask->info.taskLevel == TASK_LEVEL__AGG) {
if (taskLevel == TASK_LEVEL__AGG) {
streamTaskEnablePause(pTask);
int32_t code = streamTaskScanHistoryDataComplete(pTask);
} else { // for sink task, set normal
streamSetStatusNormal(pTask);
}
} else {
qDebug("s-task:%s receive scan-history data finish msg from upstream:0x%x(index:%d), unfinished:%d",
......
Markdown is supported
0% .
You are about to add 0 people to the discussion. Proceed with caution.
先完成此消息的编辑!
想要评论请 注册