diff --git a/src/mnode/src/mnodeVgroup.c b/src/mnode/src/mnodeVgroup.c index 593b094dc2cb4016cd1cc474d6887d977135557f..af816d7ae74b0ed16b43b64ffac997daefc9b20d 100644 --- a/src/mnode/src/mnodeVgroup.c +++ b/src/mnode/src/mnodeVgroup.c @@ -1044,14 +1044,10 @@ static void mnodeProcessAlterVnodeRsp(SRpcMsg *rpcMsg) { mnodeMsg->rpcMsg.handle, rpcMsg->ahandle); if (mnodeMsg->received != mnodeMsg->expected) return; - uint8_t msgType = mnodeMsg->rpcMsg.msgType; - if (msgType == TSDB_MSG_TYPE_CM_ALTER_DB || msgType == TSDB_MSG_TYPE_CM_CREATE_TP || msgType == TSDB_MSG_TYPE_CM_ALTER_TP) { - int32_t code = mnodeInsertAlterDbRow(pVgroup->pDb, mnodeMsg); - if (code != TSDB_CODE_SUCCESS && code != TSDB_CODE_MND_ACTION_IN_PROGRESS) { - dnodeSendRpcMWriteRsp(mnodeMsg, code); - } - } else { - dnodeSendRpcMWriteRsp(mnodeMsg, TSDB_CODE_SUCCESS); + + int32_t code = mnodeInsertAlterDbRow(pVgroup->pDb, mnodeMsg); + if (code != TSDB_CODE_SUCCESS && code != TSDB_CODE_MND_ACTION_IN_PROGRESS) { + dnodeSendRpcMWriteRsp(mnodeMsg, code); } }