diff --git a/src/benchTmq.c b/src/benchTmq.c index 34b33653..4de47719 100644 --- a/src/benchTmq.c +++ b/src/benchTmq.c @@ -73,8 +73,8 @@ static int create_topic() { if (taos_errno(res) != 0) { errorPrint("failed to create topic: %s, reason: %s\n", pConsumerInfo->topicName[i], taos_errstr(res)); - closeBenchConn(conn); taos_free_result(res); + closeBenchConn(conn); return -1; }