From 6b0b65527f788fe8a05c6e64437b268db36cdf40 Mon Sep 17 00:00:00 2001 From: Haojun Liao Date: Mon, 24 Jun 2024 19:18:31 +0800 Subject: [PATCH] fix(stream): do update the checkpoint info if not in checkpoint status. --- 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 1fddb5a97d..e4729bee7d 100644 --- a/source/libs/stream/src/streamCheckpoint.c +++ b/source/libs/stream/src/streamCheckpoint.c @@ -443,7 +443,7 @@ int32_t streamTaskUpdateTaskCheckpointInfo(SStreamTask* pTask, bool restored, SV SStreamTaskState* pStatus = streamTaskGetStatus(pTask); - if ((!restored) && (pStatus->state != TASK_STATUS__CK)) { + if (restored && (pStatus->state != TASK_STATUS__CK)) { stDebug("s-task:0x%x vgId:%d restored:%d status:%s not update checkpoint-info, checkpointId:%" PRId64 "->%" PRId64 " failed", pReq->taskId, vgId, restored, pStatus->name, pInfo->checkpointId, pReq->checkpointId);