From 8023f2bebdd20fd4ebdff7b030dcf5cddfc55240 Mon Sep 17 00:00:00 2001
From: yihaoDeng <yhdeng@taosdata.com>
Date: Thu, 16 Nov 2023 15:30:01 +0800
Subject: [PATCH] fix stream backend convert

---
 source/dnode/mnode/impl/src/mndStream.c | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)

diff --git a/source/dnode/mnode/impl/src/mndStream.c b/source/dnode/mnode/impl/src/mndStream.c
index f394cb980d..b7e659057b 100644
--- a/source/dnode/mnode/impl/src/mndStream.c
+++ b/source/dnode/mnode/impl/src/mndStream.c
@@ -1245,7 +1245,7 @@ static int32_t mndProcessStreamDoCheckpoint(SRpcMsg *pReq) {
   while (1) {
     pIter = sdbFetch(pSdb, SDB_STREAM, pIter, (void **)&pStream);
     if (pIter == NULL) break;
-    code = mndProcessStreamCheckpointTrans(pMnode, pStream, pStream->checkpointId + 1);
+    code = mndProcessStreamCheckpointTrans(pMnode, pStream, pMsg->checkpointId);
     sdbRelease(pSdb, pStream);
     if (code == -1) {
       break;