fix: fix get db name issue
This commit is contained in:
parent
16ba0c658e
commit
992912246f
|
@ -1621,16 +1621,12 @@ int32_t ctgLaunchGetTbHashsTask(SCtgTask *pTask) {
|
||||||
|
|
||||||
for (int32_t i = 0; i < pCtx->fetchNum; ++i) {
|
for (int32_t i = 0; i < pCtx->fetchNum; ++i) {
|
||||||
SCtgFetch* pFetch = taosArrayGet(pCtx->pFetchs, i);
|
SCtgFetch* pFetch = taosArrayGet(pCtx->pFetchs, i);
|
||||||
SName* pName = ctgGetFetchName(pCtx->pNames, pFetch);
|
STablesReq* pReq = taosArrayGet(pCtx->pNames, pFetch->dbIdx);
|
||||||
|
|
||||||
pTask->msgIdx = pFetch->fetchIdx;
|
pTask->msgIdx = pFetch->fetchIdx;
|
||||||
|
|
||||||
SBuildUseDBInput input = {0};
|
SBuildUseDBInput input = {0};
|
||||||
if (IS_SYS_DBNAME(pName->dbname)) {
|
strcpy(input.db, pReq->dbFName);
|
||||||
strcpy(input.db, pName->dbname);
|
|
||||||
} else {
|
|
||||||
tNameGetFullDbName(pName, input.db);
|
|
||||||
}
|
|
||||||
|
|
||||||
input.vgVersion = CTG_DEFAULT_INVALID_VERSION;
|
input.vgVersion = CTG_DEFAULT_INVALID_VERSION;
|
||||||
|
|
||||||
|
|
Loading…
Reference in New Issue