From 4d838d3dffe193e43c679f535628304a8d596873 Mon Sep 17 00:00:00 2001 From: yihaoDeng Date: Mon, 10 Jul 2023 15:51:35 +0800 Subject: [PATCH] add checkpoint --- source/dnode/mnode/impl/src/mndStream.c | 1 + 1 file changed, 1 insertion(+) diff --git a/source/dnode/mnode/impl/src/mndStream.c b/source/dnode/mnode/impl/src/mndStream.c index a28b63a0ba..63208538a3 100644 --- a/source/dnode/mnode/impl/src/mndStream.c +++ b/source/dnode/mnode/impl/src/mndStream.c @@ -994,6 +994,7 @@ static int32_t mndProcessStreamCheckpointTrans(SMnode *pMnode, SStreamObj *pStre mndTransDrop(pTrans); return -1; } + mDebug("start to trigger checkpoint for stream:%s", pStream->name); atomic_store_64(&pStream->currentTick, 1); taosWLockLatch(&pStream->lock); // 1. redo action: broadcast checkpoint source msg for all source vg