diff --git a/src/client/inc/tsclient.h b/src/client/inc/tsclient.h index a93510365f7231778ed7ce87f0939b841abe7f15..eb128237c5a9a17fbd027a7f602ad83bf256ec2c 100644 --- a/src/client/inc/tsclient.h +++ b/src/client/inc/tsclient.h @@ -133,7 +133,7 @@ typedef struct { typedef struct { uint8_t memRowType; // default is 0, that is SDataRow uint8_t compareStat; // 0 no need, 1 need compare - TDRowTLenT rowSize; + int32_t rowSize; SMemRowInfo *rowInfo; } SMemRowBuilder; diff --git a/src/client/src/tscParseInsert.c b/src/client/src/tscParseInsert.c index dffc0000e5a66112a3779899790094c60b3ad4a2..b51744d5f4c22f38a1f3165dbcad8319d9863ecd 100644 --- a/src/client/src/tscParseInsert.c +++ b/src/client/src/tscParseInsert.c @@ -1720,6 +1720,7 @@ static void parseFileSendDataBlock(void *param, TAOS_RES *tres, int32_t numOfRow // insert from .csv means full and ordered columns, thus use SDataRow all the time ASSERT(SMEM_ROW_DATA == pTableDataBlock->rowBuilder.memRowType); pTableDataBlock->rowBuilder.rowSize = extendedRowSize; + while ((readLen = tgetline(&line, &n, fp)) != -1) { if (('\r' == line[readLen - 1]) || ('\n' == line[readLen - 1])) { line[--readLen] = 0;