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

[TBASE-1229]

This commit is contained in:
slguan 2019-11-26 19:26:32 +08:00
parent b0f2738ebe
commit fcd1316531
1 changed files with 2 additions and 12 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

14
src/sdb/src/sdbEngine.c
View File

@ -353,18 +353,8 @@ int64_t sdbInsertRow(void *handle, void *row, int rowSize) {
if ((pTable->keyType != SDB_KEYTYPE_AUTO) || *((int64_t *)row)) if ((pTable->keyType != SDB_KEYTYPE_AUTO) || *((int64_t *)row))
if (sdbGetRow(handle, row)) { if (sdbGetRow(handle, row)) {
if (strcmp(pTable->name, "mnode") == 0) { sdbError("table:%s, failed to insert record, sdbVersion:%d", pTable->name, sdbVersion);
/* return -1;
* An mnode is created when the cluster is started, so conflicts may occur during synchronization.
* In this case, the version is still increased.
*/
sdbVersion++;
sdbPrint("table:%s, failed to insert record to mnodes, sdbVersion:%d", pTable->name, sdbVersion);
return -1;
} else {
sdbError("table:%s, failed to insert record, sdbVersion:%d", pTable->name, sdbVersion);
return -1;
}
} }
total_size = sizeof(SRowHead) + pTable->maxRowSize + sizeof(TSCKSUM); total_size = sizeof(SRowHead) + pTable->maxRowSize + sizeof(TSCKSUM);