From 85e4f092397a8d27c9f688d1d282e48cee16c600 Mon Sep 17 00:00:00 2001 From: Shungang Li Date: Thu, 27 Jun 2024 10:30:58 +0800 Subject: [PATCH 1/2] fix: parseCsvFile reset pTag to NULL --- source/libs/parser/src/parTranslater.c | 1 + 1 file changed, 1 insertion(+) diff --git a/source/libs/parser/src/parTranslater.c b/source/libs/parser/src/parTranslater.c index f699bfb31c..3108089232 100644 --- a/source/libs/parser/src/parTranslater.c +++ b/source/libs/parser/src/parTranslater.c @@ -12894,6 +12894,7 @@ static int32_t parseCsvFile(SMsgBuf* pMsgBuf, SParseContext* pParseCxt, SParseFi taosMemoryFreeClear(pParseFileCtx->pTag); } + pParseFileCtx->pTag = NULL; taosArrayClearEx(pParseFileCtx->aTagVals, clearTagValArrayFp); } From e61c5a40832703b156a1f9512b92c1a386146bfd Mon Sep 17 00:00:00 2001 From: Shungang Li Date: Thu, 27 Jun 2024 14:12:23 +0800 Subject: [PATCH 2/2] fix: parseOneStbRow break if token parse err --- source/libs/parser/src/parTranslater.c | 2 ++ 1 file changed, 2 insertions(+) diff --git a/source/libs/parser/src/parTranslater.c b/source/libs/parser/src/parTranslater.c index 3108089232..6bba947449 100644 --- a/source/libs/parser/src/parTranslater.c +++ b/source/libs/parser/src/parTranslater.c @@ -12819,6 +12819,8 @@ static int32_t parseOneStbRow(SMsgBuf* pMsgBuf, SParseFileContext* pParFileCtx) code = parseTbnameToken(pMsgBuf, pParFileCtx->ctbName.tname, &token, &bFoundTbName); } } + + if (TSDB_CODE_SUCCESS != code) break; } if (TSDB_CODE_SUCCESS == code) { // may fail to handle json