From f299bdb387d8c0cd573126bf0a100ec75046b50d Mon Sep 17 00:00:00 2001
From: Haojun Liao <hjliao@taosdata.com>
Date: Wed, 15 Nov 2023 14:29:01 +0800
Subject: [PATCH] fix(stream): register checkpoint trans.

---
 source/dnode/mnode/impl/src/mndStream.c | 4 +++-
 1 file changed, 3 insertions(+), 1 deletion(-)

diff --git a/source/dnode/mnode/impl/src/mndStream.c b/source/dnode/mnode/impl/src/mndStream.c
index b1b6dccf35..cadf369c5b 100644
--- a/source/dnode/mnode/impl/src/mndStream.c
+++ b/source/dnode/mnode/impl/src/mndStream.c
@@ -1262,6 +1262,8 @@ static int32_t mndProcessStreamDoCheckpoint(SRpcMsg *pReq) {
   mndTransSetDbName(pTrans, pDb, pDb);
   taosMemoryFree((void *)pDb);
 
+  mndStreamRegisterTrans(pTrans, MND_STREAM_CHECKPOINT_NAME, pDb, pDb);
+
   if (mndTransCheckConflict(pMnode, pTrans) != 0) {
     mError("failed to trigger checkpoint, checkpointId: %" PRId64 ", reason:%s", checkpointId,
            tstrerror(TSDB_CODE_MND_TRANS_CONFLICT));
@@ -1815,7 +1817,7 @@ static int32_t mndProcessPauseStreamReq(SRpcMsg *pReq) {
 
   int32_t code = mndStreamRegisterTrans(pTrans, MND_STREAM_PAUSE_NAME, pStream->sourceDb, pStream->targetDb);
 
-  // pause all tasks
+  // if nodeUpdate happened, not send pause trans
   if (mndPauseAllStreamTasks(pMnode, pTrans, pStream) < 0) {
     mError("stream:%s, failed to pause task since %s", pauseReq.name, terrstr());
     sdbRelease(pMnode->pSdb, pStream);