diff --git a/source/libs/transport/src/transCli.c b/source/libs/transport/src/transCli.c index 34a82b5fa2..5561d6fa2d 100644 --- a/source/libs/transport/src/transCli.c +++ b/source/libs/transport/src/transCli.c @@ -3283,6 +3283,7 @@ int32_t transFreeConnById(void* shandle, int64_t transpointId) { tDebug("release conn By refId %" PRId64 "", transpointId); STransMsg msg = {.info.handle = (void*)transpointId}; + pCli->msg = msg; code = transAsyncSend(pThrd->asyncPool, &pCli->q); if (code != 0) {