From 0fab9a1827da20da21d12856c89329f7868e1f4a Mon Sep 17 00:00:00 2001
From: Haojun Liao <hjliao@taosdata.com>
Date: Fri, 22 Dec 2023 00:29:49 +0800
Subject: [PATCH] other: fix syntax error.

---
 source/dnode/mnode/impl/src/mndStream.c      | 2 ++
 source/dnode/mnode/impl/src/mndStreamTrans.c | 4 ++++
 2 files changed, 6 insertions(+)

diff --git a/source/dnode/mnode/impl/src/mndStream.c b/source/dnode/mnode/impl/src/mndStream.c
index b04a707728..3ba6280f59 100644
--- a/source/dnode/mnode/impl/src/mndStream.c
+++ b/source/dnode/mnode/impl/src/mndStream.c
@@ -3006,6 +3006,7 @@ int32_t mndProcessStreamHb(SRpcMsg *pReq) {
   bool    checkpointFailed = false;
   int64_t activeCheckpointId = 0;
   int64_t streamId = 0;
+  int32_t transId = 0;
 
   SDecoder decoder = {0};
   tDecoderInit(&decoder, pReq->pCont, pReq->contLen);
@@ -3075,6 +3076,7 @@ int32_t mndProcessStreamHb(SRpcMsg *pReq) {
         if (p->checkpointFailed) {
           checkpointFailed = p->checkpointFailed;
           streamId = p->id.streamId;
+          transId = p->chkpointTransId;
         }
       }
     }
diff --git a/source/dnode/mnode/impl/src/mndStreamTrans.c b/source/dnode/mnode/impl/src/mndStreamTrans.c
index a7d4703c8c..b8a1c3d4ae 100644
--- a/source/dnode/mnode/impl/src/mndStreamTrans.c
+++ b/source/dnode/mnode/impl/src/mndStreamTrans.c
@@ -93,6 +93,8 @@ bool streamTransConflictOtherTrans(SMnode* pMnode, int64_t streamUid, const char
         mWarn("conflict with other transId:%d streamUid:%" PRIx64 ", trans:%s", tInfo.transId, tInfo.streamUid,
               tInfo.name);
         return true;
+      } else {
+        mDebug("not conflict with checkpoint trans, name:%s, continue create trans", pTransName);
       }
     } else if ((strcmp(tInfo.name, MND_STREAM_CREATE_NAME) == 0) || (strcmp(tInfo.name, MND_STREAM_DROP_NAME) == 0) ||
                (strcmp(tInfo.name, MND_STREAM_TASK_RESET_NAME) == 0)) {
@@ -100,6 +102,8 @@ bool streamTransConflictOtherTrans(SMnode* pMnode, int64_t streamUid, const char
             tInfo.name);
       return true;
     }
+  } else {
+    mDebug("stream:0x%"PRIx64" no conflict trans existed, continue create trans", streamUid);
   }
 
   if (lock) {