From 786383118c9f8ee5ee7ec608fe4f0a7a63540e09 Mon Sep 17 00:00:00 2001 From: yihaoDeng Date: Tue, 28 Nov 2023 10:39:17 +0800 Subject: [PATCH] fix drop stream case --- source/dnode/mnode/impl/src/mndStream.c | 3 +++ 1 file changed, 3 insertions(+) diff --git a/source/dnode/mnode/impl/src/mndStream.c b/source/dnode/mnode/impl/src/mndStream.c index d2bab4eebf..15cc3eb041 100644 --- a/source/dnode/mnode/impl/src/mndStream.c +++ b/source/dnode/mnode/impl/src/mndStream.c @@ -1337,6 +1337,9 @@ static int32_t mndProcessStreamCheckpointInCandid(SRpcMsg *pReq) { SCheckpointCandEntry *pEntry = pIter; SStreamObj *ps = mndAcquireStream(pMnode, pEntry->pName); + if (ps == NULL) { + continue; + } mDebug("start to launch checkpoint for stream:%s %" PRIx64 " in candidate list", pEntry->pName, pEntry->streamId); code = mndProcessStreamCheckpointTrans(pMnode, ps, pEntry->checkpointId);