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

add retry when receiving reconfigure table error

This commit is contained in:
dapan1121 2020-12-26 08:23:51 +00:00
parent 960e8c0394
commit dbfa9a0b30
1 changed files with 18 additions and 6 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

24
src/client/src/tscParseInsert.c
View File

@ -1413,13 +1413,25 @@ static void parseFileSendDataBlock(void *param, TAOS_RES *tres, int code) {
if (taos_errno(pSql) != TSDB_CODE_SUCCESS) { // handle error if (taos_errno(pSql) != TSDB_CODE_SUCCESS) { // handle error
assert(taos_errno(pSql) == code); assert(taos_errno(pSql) == code);
taos_free_result(pSql); do {
tfree(pSupporter); if (code == TSDB_CODE_TDB_TABLE_RECONFIGURE) {
fclose(fp); assert(pSql->res.numOfRows == 0);
int32_t errc = fseek(fp, 0, SEEK_SET);
if (errc < 0) {
tscError("%p failed to seek SEEK_SET since:%s", pSql, tstrerror(errno));
} else {
break;
}
}
pParentSql->res.code = code; taos_free_result(pSql);
tscQueueAsyncRes(pParentSql); tfree(pSupporter);
return; fclose(fp);
pParentSql->res.code = code;
tscQueueAsyncRes(pParentSql);
return;
} while (0);
} }
// accumulate the total submit records // accumulate the total submit records