diff --git a/src/mnode/src/mgmtChildTable.c b/src/mnode/src/mgmtChildTable.c index 9076681caa3dfc5e28f85f4c36ca96ff01978165..8fbf210118622f50df6ddf843cb0737db8bdac5f 100644 --- a/src/mnode/src/mgmtChildTable.c +++ b/src/mnode/src/mgmtChildTable.c @@ -319,9 +319,8 @@ void* mgmtCreateChildTable(SCMCreateTableMsg *pCreate, SVgObj *pVgroup, int32_t desc.type = SDB_OPER_TYPE_GLOBAL; desc.pObj = pTable; desc.table = tsChildTableSdb; - sdbInsertRow(&desc); - - if (sdbInsertRow(&desc) < 0) { + + if (sdbInsertRow(&desc) != TSDB_CODE_SUCCESS) { free(pTable); mError("ctable:%s, update sdb error", pCreate->tableId); terrno = TSDB_CODE_SDB_ERROR; diff --git a/src/mnode/src/mgmtNormalTable.c b/src/mnode/src/mgmtNormalTable.c index 4e5e4ce7cc8af2bb99685632dd2b3388a3c247d4..fde9db2d743c947148f2412099470d9058ba481a 100644 --- a/src/mnode/src/mgmtNormalTable.c +++ b/src/mnode/src/mgmtNormalTable.c @@ -334,7 +334,7 @@ void *mgmtCreateNormalTable(SCMCreateTableMsg *pCreate, SVgObj *pVgroup, int32_t desc.type = SDB_OPER_TYPE_GLOBAL; desc.pObj = pTable; desc.table = tsNormalTableSdb; - if (sdbInsertRow(&desc) < 0) { + if (sdbInsertRow(&desc) != TSDB_CODE_SUCCESS) { mError("table:%s, update sdb error", pTable->tableId); free(pTable); terrno = TSDB_CODE_SDB_ERROR; diff --git a/src/mnode/src/mgmtTable.c b/src/mnode/src/mgmtTable.c index 491e65979a5fc934970a6d899ac09e7dd06ceb07..c9a0333b1733ad122e992a63989daa8a09249f76 100644 --- a/src/mnode/src/mgmtTable.c +++ b/src/mnode/src/mgmtTable.c @@ -287,6 +287,7 @@ int32_t mgmtRetrieveShowTables(SShowObj *pShow, char *data, int32_t rows, void * createdTime = pNormalTable->createdTime; numOfColumns = pNormalTable->numOfColumns; } else { + pShow->pNode = NULL; void *pChildTableNode = sdbFetchRow(tsChildTableSdb, pShow->pNode, (void **) &pTable); if (pTable != NULL) { SChildTableObj *pChildTable = (SChildTableObj *) pTable;