diff --git a/source/dnode/mnode/impl/src/mndStb.c b/source/dnode/mnode/impl/src/mndStb.c index 2b61ae71761f863973788648c20842135d6afe92..6749fdb8774db5aa3ef3a1a0e9cac30e67504675 100644 --- a/source/dnode/mnode/impl/src/mndStb.c +++ b/source/dnode/mnode/impl/src/mndStb.c @@ -581,12 +581,11 @@ static int32_t mndProcessMCreateStbReq(SMnodeMsg *pReq) { } code = mndCreateStb(pMnode, pReq, &createReq, pDb); + if (code == 0) code = TSDB_CODE_MND_ACTION_IN_PROGRESS; CREATE_STB_OVER: - if (code != 0) { + if (code != 0 && code != TSDB_CODE_MND_ACTION_IN_PROGRESS) { mError("stb:%s, failed to create since %s", createReq.name, terrstr()); - } else { - code = TSDB_CODE_MND_ACTION_IN_PROGRESS; } mndReleaseStb(pMnode, pStb); @@ -1039,12 +1038,11 @@ static int32_t mndProcessMAlterStbReq(SMnodeMsg *pReq) { } code = mndAlterStb(pMnode, pReq, &alterReq, pDb, pStb); + if (code == 0) code = TSDB_CODE_MND_ACTION_IN_PROGRESS; ALTER_STB_OVER: - if (code != 0) { + if (code != 0 && code != TSDB_CODE_MND_ACTION_IN_PROGRESS) { mError("stb:%s, failed to alter since %s", alterReq.name, terrstr()); - } else { - code = TSDB_CODE_MND_ACTION_IN_PROGRESS; } mndReleaseStb(pMnode, pStb);