diff --git a/source/libs/transport/src/transCli.c b/source/libs/transport/src/transCli.c index a18e3ad1aab4f62de363f1b3e1332e62a0203924..46658e935283b754677eeab4fff17fc184ed6681 100644 --- a/source/libs/transport/src/transCli.c +++ b/source/libs/transport/src/transCli.c @@ -389,6 +389,7 @@ static void addConnToPool(void* pool, SCliConn* conn) { conn->status = ConnNormal; // list already create before assert(plist != NULL); + taosArrayClear(conn->cliMsgs); QUEUE_PUSH(&plist->conn, &conn->conn); assert(!QUEUE_IS_EMPTY(&plist->conn)); }