From 2541d1912473b8e25414e30a4e392114911ae40b Mon Sep 17 00:00:00 2001
From: Liu Jicong <liujicong@qq.com>
Date: Wed, 16 Feb 2022 21:22:07 +0800
Subject: [PATCH] use full name to create topic

---
 source/client/src/tmq.c                | 5 +----
 source/dnode/mnode/impl/src/mndTopic.c | 2 +-
 2 files changed, 2 insertions(+), 5 deletions(-)

diff --git a/source/client/src/tmq.c b/source/client/src/tmq.c
index f8d9cfe44b..419d6294a7 100644
--- a/source/client/src/tmq.c
+++ b/source/client/src/tmq.c
@@ -384,16 +384,13 @@ TAOS_RES* tmq_create_topic(TAOS* taos, const char* topicName, const char* sql, i
   tNameFromString(&name, dbName, T_NAME_ACCT | T_NAME_DB);
   tNameFromString(&name, topicName, T_NAME_TABLE);
 
-  char topicFname[TSDB_TOPIC_FNAME_LEN] = {0};
-  tNameExtractFullName(&name, topicFname);
-
   SMCreateTopicReq req = {
       .igExists = 1,
       .physicalPlan = (char*)pStr,
       .sql = (char*)sql,
       .logicalPlan = (char*)"no logic plan",
   };
-  memcpy(req.name, topicName, TSDB_TOPIC_FNAME_LEN);
+  tNameExtractFullName(&name, req.name);
 
   int   tlen = tSerializeMCreateTopicReq(NULL, 0, &req);
   void* buf = malloc(tlen);
diff --git a/source/dnode/mnode/impl/src/mndTopic.c b/source/dnode/mnode/impl/src/mndTopic.c
index e7308b833e..deac89d68a 100644
--- a/source/dnode/mnode/impl/src/mndTopic.c
+++ b/source/dnode/mnode/impl/src/mndTopic.c
@@ -26,7 +26,7 @@
 #include "mndVgroup.h"
 #include "tname.h"
 
-#define MND_TOPIC_VER_NUMBER 1
+#define MND_TOPIC_VER_NUMBER   1
 #define MND_TOPIC_RESERVE_SIZE 64
 
 static int32_t mndTopicActionInsert(SSdb *pSdb, SMqTopicObj *pTopic);