diff --git a/src/client/src/tscParseInsert.c b/src/client/src/tscParseInsert.c index 0c0738677d6ee83b289b9b63996da2fabe611ef4..4f817b222dcffed79e807b231cfd142e85c5c633 100644 --- a/src/client/src/tscParseInsert.c +++ b/src/client/src/tscParseInsert.c @@ -453,6 +453,8 @@ int tsParseOneRow(char **str, STableDataBlocks *pDataBlocks, int16_t timePrec, b char *row = pDataBlocks->pData + ((*isConverted) ? (pDataBlocks->size - rowSize) : pDataBlocks->size); // skip the SSubmitBlk header + *isConverted = false; + SParsedDataColInfo *spd = &pDataBlocks->boundColumnInfo; STableMeta * pTableMeta = pDataBlocks->pTableMeta; SSchema * schema = tscGetTableSchema(pTableMeta); @@ -461,7 +463,6 @@ int tsParseOneRow(char **str, STableDataBlocks *pDataBlocks, int16_t timePrec, b int32_t kvLen = pBuilder->kvRowInitLen; bool isParseBindParam = false; - *isConverted = false; initSMemRow(row, pBuilder->memRowType, pDataBlocks, spd->numOfBound); // 1. set the parsed value from sql string