未验证 提交 8b72cf39 编写于 作者: sangshuduo's avatar sangshuduo 提交者: GitHub

[TD-3775]<fix>: taosdemo interlace rows more than insert rows. (#5819)

Co-authored-by: NShuduo Sang <sdsang@taosdata.com>
上级 a37f5a42
...@@ -4801,6 +4801,9 @@ static void* syncWriteInterlace(threadInfo *pThreadInfo) { ...@@ -4801,6 +4801,9 @@ static void* syncWriteInterlace(threadInfo *pThreadInfo) {
int64_t insertRows = (superTblInfo)?superTblInfo->insertRows:g_args.num_of_DPT; int64_t insertRows = (superTblInfo)?superTblInfo->insertRows:g_args.num_of_DPT;
int interlaceRows = superTblInfo?superTblInfo->interlaceRows:g_args.interlace_rows; int interlaceRows = superTblInfo?superTblInfo->interlaceRows:g_args.interlace_rows;
if (interlaceRows > insertRows)
interlaceRows = insertRows;
if (interlaceRows > g_args.num_of_RPR) if (interlaceRows > g_args.num_of_RPR)
interlaceRows = g_args.num_of_RPR; interlaceRows = g_args.num_of_RPR;
...@@ -4849,9 +4852,6 @@ static void* syncWriteInterlace(threadInfo *pThreadInfo) { ...@@ -4849,9 +4852,6 @@ static void* syncWriteInterlace(threadInfo *pThreadInfo) {
assert(pThreadInfo->ntables > 0); assert(pThreadInfo->ntables > 0);
if (interlaceRows > g_args.num_of_RPR)
interlaceRows = g_args.num_of_RPR;
int batchPerTbl = interlaceRows; int batchPerTbl = interlaceRows;
int batchPerTblTimes; int batchPerTblTimes;
......
Markdown is supported
0% .
You are about to add 0 people to the discussion. Proceed with caution.
先完成此消息的编辑!
想要评论请 注册