From b1b324606606ddfa1934d2dc732659706c038735 Mon Sep 17 00:00:00 2001 From: Haojun Liao Date: Fri, 26 Apr 2024 17:03:01 +0800 Subject: [PATCH] fix(stream): update the checkpoint executed transId range. --- source/dnode/vnode/src/tq/tq.c | 2 +- source/libs/stream/src/streamCheckStatus.c | 2 +- 2 files changed, 2 insertions(+), 2 deletions(-) diff --git a/source/dnode/vnode/src/tq/tq.c b/source/dnode/vnode/src/tq/tq.c index cf985cd164..fe7daf2bf1 100644 --- a/source/dnode/vnode/src/tq/tq.c +++ b/source/dnode/vnode/src/tq/tq.c @@ -1165,7 +1165,7 @@ int32_t tqProcessTaskCheckPointSourceReq(STQ* pTq, SRpcMsg* pMsg, SRpcMsg* pRsp) return TSDB_CODE_SUCCESS; } else { // checkpoint already finished, and not in checkpoint status - if (req.checkpointId == pTask->chkInfo.checkpointId) { + if (req.checkpointId <= pTask->chkInfo.checkpointId) { tqWarn("s-task:%s repeatly recv checkpoint-source msg checkpointId:%" PRId64 " transId:%d already handled, ignore and discard", pTask->id.idStr, req.checkpointId, req.transId); diff --git a/source/libs/stream/src/streamCheckStatus.c b/source/libs/stream/src/streamCheckStatus.c index 0f4662594f..d164d01934 100644 --- a/source/libs/stream/src/streamCheckStatus.c +++ b/source/libs/stream/src/streamCheckStatus.c @@ -338,7 +338,7 @@ int32_t streamTaskCompleteCheckRsp(STaskCheckInfo* pInfo, bool lock, const char* } if (!pInfo->inCheckProcess) { - stWarn("s-task:%s already not in-check-procedure", id); +// stWarn("s-task:%s already not in-check-procedure", id); } int64_t el = (pInfo->startTs != 0) ? (taosGetTimestampMs() - pInfo->startTs) : 0;