diff --git a/src/mnode/src/mnodeSdb.c b/src/mnode/src/mnodeSdb.c index aff13f46bc8ca047ed33b209eb1dd2289b1dca10..86df1f5303e6af4e3d87d89139fe370202c44265 100644 --- a/src/mnode/src/mnodeSdb.c +++ b/src/mnode/src/mnodeSdb.c @@ -503,7 +503,7 @@ static int32_t sdbDeleteHash(SSdbTable *pTable, SSdbOper *pOper) { pTable->numOfRows--; pthread_mutex_unlock(&pTable->mutex); - sdbTrace("table:%s, delete record:%s from hash, numOfRows:%" PRId64 "version:%" PRIu64, pTable->tableName, + sdbTrace("table:%s, delete record:%s from hash, numOfRows:%" PRId64 " version:%" PRIu64, pTable->tableName, sdbGetKeyStrFromObj(pTable, pOper->pObj), pTable->numOfRows, sdbGetVersion()); int8_t *updateEnd = pOper->pObj + pTable->refCountPos - 1; diff --git a/src/mnode/src/mnodeTable.c b/src/mnode/src/mnodeTable.c index bffb002cbd2de64124a252aaf46584adbf2c8aaf..6e72285c5a6df9e9b6d4665c6723e311bae6aaac 100644 --- a/src/mnode/src/mnodeTable.c +++ b/src/mnode/src/mnodeTable.c @@ -849,7 +849,7 @@ static int32_t mnodeProcessDropSuperTableMsg(SMnodeMsg *pMsg) { }; int32_t code = sdbDeleteRow(&oper); - if (code == TSDB_CODE_MND_ACTION_IN_PROGRESS) { + if (code == TSDB_CODE_SUCCESS) { mLPrint("stable:%s, is dropped from sdb, result:%s", pStable->info.tableId, tstrerror(code)); if (pMsg != NULL) code = TSDB_CODE_MND_ACTION_IN_PROGRESS; } @@ -1585,7 +1585,7 @@ static int32_t mnodeProcessCreateChildTableMsg(SMnodeMsg *pMsg) { pMsg->pVgroup = pVgroup; mnodeIncVgroupRef(pVgroup); } - + pMsg->pTable = (STableObj *)mnodeDoCreateChildTable(pMsg, sid); if (pMsg->pTable == NULL) { return terrno;