diff --git a/source/libs/stream/src/streamCheckpoint.c b/source/libs/stream/src/streamCheckpoint.c
index 6dee0d363b..d8b86edf53 100644
--- a/source/libs/stream/src/streamCheckpoint.c
+++ b/source/libs/stream/src/streamCheckpoint.c
@@ -464,7 +464,7 @@ int32_t streamTaskUpdateTaskCheckpointInfo(SStreamTask* pTask, bool restored, SV
   }
 
   ASSERT(pInfo->checkpointId <= pReq->checkpointId && pInfo->checkpointVer <= pReq->checkpointVer &&
-         pInfo->processedVer >= pReq->checkpointVer);
+         pInfo->processedVer <= pReq->checkpointVer);
 
   pInfo->checkpointId = pReq->checkpointId;
   pInfo->checkpointVer = pReq->checkpointVer;