fix(stream): cleanup the checkpoint trans & task info in execInfo

2024-01-03 19:18:06 +08:00 · 2024-01-03 19:18:06 +08:00 · b06ccc0ca7
parent 4399867e14
commit b06ccc0ca7
1 changed files with 10 additions and 0 deletions
--- a/source/dnode/mnode/impl/src/mndStream.c
+++ b/source/dnode/mnode/impl/src/mndStream.c
@ -1500,6 +1500,16 @@ int32_t mndDropStreamByDb(SMnode *pMnode, STrans *pTrans, SDbObj *pDb) {
          return -1;
        }
 #endif
+
+        // kill the related checkpoint trans
+        int32_t transId = mndStreamGetRelCheckpointTrans(pMnode, pStream->uid);
+        if (transId != 0) {
+          killCheckpointTransImpl(pMnode, transId, pStream->sourceDb);
+        }
+
+        // drop the stream obj in execInfo
+        removeStreamTasksInBuf(pStream, &execInfo);
+
        if (mndPersistDropStreamLog(pMnode, pTrans, pStream) < 0) {
          sdbRelease(pSdb, pStream);
          sdbCancelFetch(pSdb, pIter);