diff --git a/source/dnode/mnode/impl/src/mndStream.c b/source/dnode/mnode/impl/src/mndStream.c index a28b63a0baa621dd85f434f4fe0e371f6702d388..63208538a35c0f3232b80152c0cd9591a8174fae 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