From 57ef43ba1871f969b74c4b010ff012be2ee57af0 Mon Sep 17 00:00:00 2001 From: Haojun Liao Date: Tue, 22 Aug 2023 18:16:46 +0800 Subject: [PATCH] fix(stream): set sink task status to enable the checkpoint. --- source/libs/stream/src/streamRecover.c | 5 ++++- 1 file changed, 4 insertions(+), 1 deletion(-) diff --git a/source/libs/stream/src/streamRecover.c b/source/libs/stream/src/streamRecover.c index c4a8400b43..88d57b5992 100644 --- a/source/libs/stream/src/streamRecover.c +++ b/source/libs/stream/src/streamRecover.c @@ -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",