diff --git a/source/dnode/mnode/impl/src/mndStream.c b/source/dnode/mnode/impl/src/mndStream.c index 6af54aeb2e..337e07756b 100644 --- a/source/dnode/mnode/impl/src/mndStream.c +++ b/source/dnode/mnode/impl/src/mndStream.c @@ -1330,8 +1330,6 @@ static int32_t mndProcessStreamCheckpoint(SRpcMsg *pReq) { int32_t size = taosArrayGetSize(pList); if (size == 0) { taosArrayDestroy(pList); - taosArrayDestroy(pLongChkpts); - return code; } @@ -1344,8 +1342,6 @@ static int32_t mndProcessStreamCheckpoint(SRpcMsg *pReq) { "checkpoint trans are not allowed, wait for 30s", numOfQual, tsStreamCheckpointInterval, numOfCheckpointTrans, tsMaxConcurrentCheckpoint); taosArrayDestroy(pList); - taosArrayDestroy(pLongChkpts); - return code; } @@ -1385,8 +1381,6 @@ static int32_t mndProcessStreamCheckpoint(SRpcMsg *pReq) { } taosArrayDestroy(pList); - taosArrayDestroy(pLongChkpts); - return code; }