diff --git a/source/common/test/msgTypeTable.ini b/source/common/test/msgTypeTable.ini index e31f21fd27..add1128850 100644 --- a/source/common/test/msgTypeTable.ini +++ b/source/common/test/msgTypeTable.ini @@ -439,6 +439,7 @@ TDMT_STREAM_DROP_RSP = 1054 TDMT_STREAM_RETRIEVE_TRIGGER = 1055 TDMT_STREAM_RETRIEVE_TRIGGER_RSP = 1056 TDMT_MND_RESET_STREAM = 1057 +TDMT_MND_RESET_STREAM_RSP = 1058 TDMT_SYNC_TIMEOUT = 1537 TDMT_SYNC_TIMEOUT_RSP = 1538 TDMT_SYNC_TIMEOUT_ELECTION = 1539 diff --git a/source/dnode/mnode/impl/src/mndStream.c b/source/dnode/mnode/impl/src/mndStream.c index 963f69de64..577efd155a 100644 --- a/source/dnode/mnode/impl/src/mndStream.c +++ b/source/dnode/mnode/impl/src/mndStream.c @@ -1914,6 +1914,8 @@ static int32_t mndProcessResetStreamReq(SRpcMsg *pReq) { TAOS_RETURN(TSDB_CODE_INVALID_MSG); } + mDebug("recv reset stream req, stream:%s", resetReq.name); + code = mndAcquireStream(pMnode, resetReq.name, &pStream); if (pStream == NULL || code != 0) { if (resetReq.igNotExists) {