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);