From 646b339bdecbfd6298930cd60eb1cee54ddc2195 Mon Sep 17 00:00:00 2001 From: Haojun Liao Date: Wed, 30 Aug 2023 14:28:45 +0800 Subject: [PATCH] fix(stream): not enable the pause before receive all finish rsp --- source/libs/stream/src/streamRecover.c | 3 +-- 1 file changed, 1 insertion(+), 2 deletions(-) diff --git a/source/libs/stream/src/streamRecover.c b/source/libs/stream/src/streamRecover.c index eb1f4e6a45..2ca1612290 100644 --- a/source/libs/stream/src/streamRecover.c +++ b/source/libs/stream/src/streamRecover.c @@ -465,8 +465,7 @@ int32_t streamProcessScanHistoryFinishReq(SStreamTask* pTask, SStreamScanHistory // mnode will not send the pause/resume message to the sink task, so no need to enable the pause for sink tasks. if (taskLevel == TASK_LEVEL__AGG) { - streamTaskEnablePause(pTask); - int32_t code = streamTaskScanHistoryDataComplete(pTask); + /*int32_t code = */streamTaskScanHistoryDataComplete(pTask); } else { // for sink task, set normal if (pTask->status.taskStatus != TASK_STATUS__PAUSE && pTask->status.taskStatus != TASK_STATUS__STOP && pTask->status.taskStatus != TASK_STATUS__DROPPING) {