xxq250
/
homework-jianmu
1
0
Fork 0
Code Issues Pull Requests 1 Actions Packages Projects Releases Wiki Activity

TD-1832

This commit is contained in:
Shengliang Guan 2020-10-27 14:16:26 +00:00
parent 5b4dc831d6
commit dab726abe9
1 changed files with 10 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

11
src/mnode/src/mnodeSdb.c
View File

@ -273,6 +273,8 @@ static void sdbConfirmForward(void *ahandle, void *param, int32_t code) {
tstrerror(code)); tstrerror(code));
} }
if (((SSdbTable *)pOper->table)->tableId == SDB_TABLE_CTABLE)
pOper->retCode = TSDB_CODE_MND_APP_ERROR;
// failed to forward, need revert insert // failed to forward, need revert insert
if (pOper->retCode != TSDB_CODE_SUCCESS) { if (pOper->retCode != TSDB_CODE_SUCCESS) {
SWalHead *pHead = (void *)pOper + sizeof(SSdbOper) + SDB_SYNC_HACK; SWalHead *pHead = (void *)pOper + sizeof(SSdbOper) + SDB_SYNC_HACK;
@ -281,7 +283,14 @@ static void sdbConfirmForward(void *ahandle, void *param, int32_t code) {
((SSdbTable *)pOper->table)->tableName, pOper->pObj, sdbGetKeyStr(pOper->table, pHead->cont), ((SSdbTable *)pOper->table)->tableName, pOper->pObj, sdbGetKeyStr(pOper->table, pHead->cont),
pHead->version, action, tstrerror(pOper->retCode)); pHead->version, action, tstrerror(pOper->retCode));
if (action == SDB_ACTION_INSERT) { if (action == SDB_ACTION_INSERT) {
sdbDeleteHash(pOper->table, pOper); // It's better to create a table in two stages, create it first and then set it success
//sdbDeleteHash(pOper->table, pOper);
SSdbOper oper = {
.type = SDB_OPER_GLOBAL,
.table = pOper->table,
.pObj = pOper->pObj
};
sdbDeleteRow(&oper);
} }
} }