diff --git a/source/libs/transport/src/transCli.c b/source/libs/transport/src/transCli.c index 4e710fbaeb..82dc099940 100644 --- a/source/libs/transport/src/transCli.c +++ b/source/libs/transport/src/transCli.c @@ -3119,9 +3119,9 @@ int32_t transSendRequest(void* pInstRef, const SEpSet* pEpSet, STransMsg* pReq, return (code == TSDB_CODE_RPC_ASYNC_MODULE_QUIT ? TSDB_CODE_RPC_MODULE_QUIT : code); } - if (pReq->msgType == TDMT_SCH_DROP_TASK) { - TAOS_UNUSED(transReleaseCliHandle(pReq->info.handle)); - } + // if (pReq->msgType == TDMT_SCH_DROP_TASK) { + // TAOS_UNUSED(transReleaseCliHandle(pReq->info.handle)); + // } transReleaseExHandle(transGetInstMgt(), (int64_t)pInstRef); return 0; @@ -3172,9 +3172,9 @@ int32_t transSendRequestWithId(void* pInstRef, const SEpSet* pEpSet, STransMsg* return (code == TSDB_CODE_RPC_ASYNC_MODULE_QUIT ? TSDB_CODE_RPC_MODULE_QUIT : code); } - if (pReq->msgType == TDMT_SCH_DROP_TASK) { - TAOS_UNUSED(transReleaseCliHandle(pReq->info.handle)); - } + // if (pReq->msgType == TDMT_SCH_DROP_TASK) { + // TAOS_UNUSED(transReleaseCliHandle(pReq->info.handle)); + // } transReleaseExHandle(transGetRefMgt(), *transpointId); transReleaseExHandle(transGetInstMgt(), (int64_t)pInstRef); return 0;