From 5966b4f83fb4e82b447823071465fffc7e8974e6 Mon Sep 17 00:00:00 2001 From: Haojun Liao Date: Fri, 21 Jun 2024 17:17:39 +0800 Subject: [PATCH] fix(stream): fix error in assert. --- 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 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;