diff --git a/src/client/src/tscParseInsert.c b/src/client/src/tscParseInsert.c index f567234d938f5a6c339cb99553ce90a618fa3b19..66918d1917f62da8221eb9b357cd810159407e0e 100644 --- a/src/client/src/tscParseInsert.c +++ b/src/client/src/tscParseInsert.c @@ -569,8 +569,11 @@ int tsParseOneRow(char **str, STableDataBlocks *pDataBlocks, int16_t timePrec, i // 4. perform the convert if (isNeedConvertRow) { // put converted row to next location to minimize the memcpy - convertSMemRow(row + rowSize, row, pDataBlocks); - *isConverted = true; + ++(*convertOffset); + convertSMemRow(row + (*convertOffset) * rowSize, row, pDataBlocks); + pDataBlocks->ordered = false; + } else { + *convertOffset = 0; } }