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