From 0f98f4daa58201d2bf5344c6a71530d6d19ba48c Mon Sep 17 00:00:00 2001
From: yihaoDeng <yhdeng@taosdata.com>
Date: Wed, 8 Nov 2023 20:29:37 +0800
Subject: [PATCH] change check out seq

---
 source/dnode/mnode/impl/src/mndStream.c | 5 +----
 1 file changed, 1 insertion(+), 4 deletions(-)

diff --git a/source/dnode/mnode/impl/src/mndStream.c b/source/dnode/mnode/impl/src/mndStream.c
index fcdf024a59..b3fd81f450 100644
--- a/source/dnode/mnode/impl/src/mndStream.c
+++ b/source/dnode/mnode/impl/src/mndStream.c
@@ -1219,14 +1219,11 @@ static int32_t mndProcessStreamDoCheckpoint(SRpcMsg *pReq) {
   if ((code = mndCheckNodeStatus(pMnode)) != 0) {
     return code;
   }
-
   SMStreamDoCheckpointMsg *pMsg = (SMStreamDoCheckpointMsg *)pReq->pCont;
-  int64_t                  checkpointId = pMsg->checkpointId;
   while (1) {
     pIter = sdbFetch(pSdb, SDB_STREAM, pIter, (void **)&pStream);
     if (pIter == NULL) break;
-
-    code = mndProcessStreamCheckpointTrans(pMnode, pStream, checkpointId);
+    code = mndProcessStreamCheckpointTrans(pMnode, pStream, pStream->checkpointId + 1);
     sdbRelease(pSdb, pStream);
     if (code == -1) {
       break;