From d01670d49a8ec2fb4891d1ff1476ee3786df39b3 Mon Sep 17 00:00:00 2001 From: Haojun Liao Date: Thu, 12 Sep 2024 14:06:25 +0800 Subject: [PATCH] fix(stream): fix the error in the checkpoint-trigger confirm condition. --- source/libs/stream/src/streamDispatch.c | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/source/libs/stream/src/streamDispatch.c b/source/libs/stream/src/streamDispatch.c index eb6c9c1a66..32fb67dd98 100644 --- a/source/libs/stream/src/streamDispatch.c +++ b/source/libs/stream/src/streamDispatch.c @@ -1494,7 +1494,7 @@ int32_t streamProcessDispatchRsp(SStreamTask* pTask, SStreamDispatchRsp* pRsp, i streamMutexLock(&pTask->lock); SStreamTaskState s = streamTaskGetStatus(pTask); triggerDispatchRsp = (s.state == TASK_STATUS__CK) && (pInfo->activeId == pMsgInfo->checkpointId) && - (pInfo->transId != pMsgInfo->transId); + (pInfo->transId == pMsgInfo->transId); tmpCheckpointId = pInfo->activeId; tmpTranId = pInfo->transId; pStatus = s.name;