未验证 提交 4a2bbfc6 编写于 作者: H haojun Liao 提交者: GitHub

Merge pull request #4733 from taosdata/hotfix/TD-2557

[TD-2557]<fix>:insert from file failed after changing stable
...@@ -1413,6 +1413,17 @@ static void parseFileSendDataBlock(void *param, TAOS_RES *tres, int code) { ...@@ -1413,6 +1413,17 @@ 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);
do {
if (code == TSDB_CODE_TDB_TABLE_RECONFIGURE) {
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;
}
}
taos_free_result(pSql); taos_free_result(pSql);
tfree(pSupporter); tfree(pSupporter);
fclose(fp); fclose(fp);
...@@ -1420,6 +1431,7 @@ static void parseFileSendDataBlock(void *param, TAOS_RES *tres, int code) { ...@@ -1420,6 +1431,7 @@ static void parseFileSendDataBlock(void *param, TAOS_RES *tres, int code) {
pParentSql->res.code = code; pParentSql->res.code = code;
tscQueueAsyncRes(pParentSql); tscQueueAsyncRes(pParentSql);
return; return;
} while (0);
} }
// accumulate the total submit records // accumulate the total submit records
......
Markdown is supported
0% .
You are about to add 0 people to the discussion. Proceed with caution.
先完成此消息的编辑!
想要评论请 注册