From a222e9ad7b7835c4f9ac7a7b1c125edf9fd399cc Mon Sep 17 00:00:00 2001 From: dapan1121 Date: Wed, 23 Nov 2022 16:09:03 +0800 Subject: [PATCH] fix: update sysdb vgroup info after db dropped --- source/client/src/clientMsgHandler.c | 10 ++++++++-- 1 file changed, 8 insertions(+), 2 deletions(-) diff --git a/source/client/src/clientMsgHandler.c b/source/client/src/clientMsgHandler.c index 1931704909..fe35d9679d 100644 --- a/source/client/src/clientMsgHandler.c +++ b/source/client/src/clientMsgHandler.c @@ -327,8 +327,14 @@ int32_t processDropDbRsp(void* param, SDataBuf* pMsg, int32_t code) { int32_t code = catalogGetHandle(pRequest->pTscObj->pAppInfo->clusterId, &pCatalog); if (TSDB_CODE_SUCCESS == code) { catalogRemoveDB(pCatalog, dropdbRsp.db, dropdbRsp.uid); - catalogRemoveDB(pCatalog, TSDB_INFORMATION_SCHEMA_DB, 0); - catalogRemoveDB(pCatalog, TSDB_PERFORMANCE_SCHEMA_DB, 0); + STscObj* pTscObj = pRequest->pTscObj; + + SRequestConnInfo conn = {.pTrans = pTscObj->pAppInfo->pTransporter, + .requestId = pRequest->requestId, + .requestObjRefId = pRequest->self, + .mgmtEps = getEpSet_s(&pTscObj->pAppInfo->mgmtEp)}; + catalogRefreshDBVgInfo(pCatalog, &conn, TSDB_INFORMATION_SCHEMA_DB); + catalogRefreshDBVgInfo(pCatalog, &conn, TSDB_PERFORMANCE_SCHEMA_DB); } }