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;