fix:make version compatible

This commit is contained in:
wangmm0220 2023-06-01 17:03:02 +08:00
parent 69499b9582
commit bb772e2062
1 changed files with 5 additions and 6 deletions

View File

@ -924,13 +924,12 @@ static int32_t mndRetrieveTopic(SRpcMsg *pReq, SShowObj *pShow, SSDataBlock *pBl
}else if(pTopic->subType == TOPIC_SUB_TYPE__TABLE){ }else if(pTopic->subType == TOPIC_SUB_TYPE__TABLE){
SStbObj *pStb = mndAcquireStb(pMnode, pTopic->stbName); SStbObj *pStb = mndAcquireStb(pMnode, pTopic->stbName);
if (pStb == NULL) { if (pStb == NULL) {
terrno = TSDB_CODE_MND_STB_NOT_EXIST; STR_TO_VARSTR(schemaJson, "NULL");
taosMemoryFree(schemaJson); mError("mndRetrieveTopic mndAcquireStb null stbName:%s", pTopic->stbName);
return -1; }else{
}
schemaToJson(pStb->pColumns, pStb->numOfColumns, schemaJson); schemaToJson(pStb->pColumns, pStb->numOfColumns, schemaJson);
mndReleaseStb(pMnode, pStb); mndReleaseStb(pMnode, pStb);
}
}else{ }else{
STR_TO_VARSTR(schemaJson, "NULL"); STR_TO_VARSTR(schemaJson, "NULL");
} }