diff --git a/src/client/src/tscParseInsert.c b/src/client/src/tscParseInsert.c index 0197d6a075820fde55ac6882f6fc934de9de9c9b..01f9f3f3604b7c157b31d7117b5e00ea26cf62de 100644 --- a/src/client/src/tscParseInsert.c +++ b/src/client/src/tscParseInsert.c @@ -1192,6 +1192,10 @@ static int tscInsertDataFromFile(SSqlObj *pSql, FILE *fp) { char *lineptr = line; strtolower(line, line); + if (numOfRows >= maxRows || pTableDataBlock->size + pMeterMeta->rowSize >= pTableDataBlock->nAllocSize) { + maxRows += tscAllocateMemIfNeed(pTableDataBlock, pMeterMeta->rowSize); + } + len = tsParseOneRowData(&lineptr, pTableDataBlock, pSchema, &spd, pCmd->payload, pMeterMeta->precision); if (len <= 0) return -1;