This commit is contained in:
hjxilinx 2019-10-12 22:01:45 +08:00
parent b2bbcd809d
commit 24565c3490
1 changed files with 4 additions and 0 deletions

View File

@ -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;