From 1d110953c9bc091f2181b9def8b7f6018161c68f Mon Sep 17 00:00:00 2001 From: Haojun Liao Date: Tue, 30 Jan 2024 15:23:54 +0800 Subject: [PATCH] refactor: do some internal refactor. --- source/libs/stream/src/streamExec.c | 5 +---- 1 file changed, 1 insertion(+), 4 deletions(-) diff --git a/source/libs/stream/src/streamExec.c b/source/libs/stream/src/streamExec.c index 0c56679c14..b0170d5083 100644 --- a/source/libs/stream/src/streamExec.c +++ b/source/libs/stream/src/streamExec.c @@ -400,11 +400,8 @@ int32_t streamDoTransferStateToStreamTask(SStreamTask* pTask) { streamTaskReleaseState(pTask); streamTaskReloadState(pStreamTask); - // 3. scan wal file from the beginning till the end version of fill-history task. - streamTaskSupplementaryScan(pStreamTask); - // 3. send msg to mnode to launch a checkpoint to keep the state for current stream -// streamTaskSendCheckpointReq(pStreamTask); + streamTaskSendCheckpointReq(pStreamTask); // 4. assign the status to the value that will be kept in disk pStreamTask->status.taskStatus = streamTaskGetStatus(pStreamTask)->state;