merge from 3.0

This commit is contained in:
Liu Jicong 2022-01-24 21:46:37 +08:00
parent b152a2467b
commit f3aa81399c
1 changed files with 1 additions and 1 deletions

View File

@ -380,7 +380,7 @@ TAOS_RES* tmq_subscribe(tmq_t* tmq, tmq_list_t* topic_list) {
char* topicName = topic_list->elems[i];
SName name = {0};
char* dbName = getConnectionDB(tmq->pTscObj);
char* dbName = getDbOfConnection(tmq->pTscObj);
tNameSetDbName(&name, tmq->pTscObj->acctId, dbName, strlen(dbName));
tNameFromString(&name, topicName, T_NAME_TABLE);