From 393369fcd8ee0fe0e271337ae70af23a2780e784 Mon Sep 17 00:00:00 2001 From: Haojun Liao Date: Sun, 23 Jun 2024 00:40:12 +0800 Subject: [PATCH] fix(stream):clear checkpoint-ready msg. --- source/libs/stream/src/streamCheckpoint.c | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/source/libs/stream/src/streamCheckpoint.c b/source/libs/stream/src/streamCheckpoint.c index ad33d44b15..1fddb5a97d 100644 --- a/source/libs/stream/src/streamCheckpoint.c +++ b/source/libs/stream/src/streamCheckpoint.c @@ -470,7 +470,7 @@ int32_t streamTaskUpdateTaskCheckpointInfo(SStreamTask* pTask, bool restored, SV pInfo->checkpointVer = pReq->checkpointVer; pInfo->checkpointTime = pReq->checkpointTs; - streamTaskClearCheckInfo(pTask, false); + streamTaskClearCheckInfo(pTask, true); if (pStatus->state == TASK_STATUS__CK) { // todo handle error