From dd4740e5a4a2644bab8bd6d6d3dbba9fbc753b34 Mon Sep 17 00:00:00 2001 From: yihaoDeng Date: Fri, 14 Jul 2023 03:45:30 +0000 Subject: [PATCH] add checkpoint --- source/dnode/mnode/impl/src/mndStream.c | 5 ++--- 1 file changed, 2 insertions(+), 3 deletions(-) diff --git a/source/dnode/mnode/impl/src/mndStream.c b/source/dnode/mnode/impl/src/mndStream.c index 2da3a1365a..adf7d85aeb 100644 --- a/source/dnode/mnode/impl/src/mndStream.c +++ b/source/dnode/mnode/impl/src/mndStream.c @@ -1166,7 +1166,7 @@ static int32_t mndProcessStreamDoCheckpoint(SRpcMsg *pReq) { mError("failed to trigger checkpoint, reason: %s", tstrerror(TSDB_CODE_OUT_OF_MEMORY)); return -1; } - mDebug("start to trigger checkpoint"); + mDebug("start to trigger checkpoint, checkpointId: %" PRId64 "", checkpointId); mndTransSetDbName(pTrans, "checkpoint", "checkpoint"); if (mndTransCheckConflict(pMnode, pTrans) != 0) { @@ -1181,11 +1181,10 @@ static int32_t mndProcessStreamDoCheckpoint(SRpcMsg *pReq) { if (pIter == NULL) break; code = mndAddStreamCheckpointToTrans(pTrans, pStream, pMnode, checkpointId); + sdbRelease(pSdb, pStream); if (code == -1) { - sdbRelease(pSdb, pStream); break; } - sdbRelease(pSdb, pStream); } if (code == 0) { if (mndTransPrepare(pMnode, pTrans) != 0) {