diff --git a/source/libs/parser/src/parInsert.c b/source/libs/parser/src/parInsert.c index b01b37469661dd547932d316ac6b393758c6aef6..e1b9fce5e803a2b029a42a70088e6708d495543b 100644 --- a/source/libs/parser/src/parInsert.c +++ b/source/libs/parser/src/parInsert.c @@ -250,7 +250,6 @@ static void buildMsgHeader(STableDataBlocks* src, SVgDataBlocks* blocks) { SSubmitReq* submit = (SSubmitReq*)blocks->pData; submit->header.vgId = htonl(blocks->vg.vgId); submit->header.contLen = htonl(blocks->size); - strcpy(submit->header.dbFName, src->dbFName); submit->length = submit->header.contLen; submit->numOfBlocks = htonl(blocks->numOfTables); SSubmitBlk* blk = (SSubmitBlk*)(submit + 1); @@ -1049,4 +1048,6 @@ int32_t parseInsertSql(SParseContext* pContext, SQuery** pQuery) { if (TSDB_CODE_SUCCESS == code) { code = parseInsertBody(&context); } - dest \ No newline at end of file + destroyInsertParseContext(&context); + return code; +} diff --git a/source/libs/qworker/test/qworkerTests.cpp b/source/libs/qworker/test/qworkerTests.cpp index 04c36b97da0f53620160d90ffe3a04bfba353a2b..2d27884466b9ab628bb71e53b79c950966ab3d13 100644 --- a/source/libs/qworker/test/qworkerTests.cpp +++ b/source/libs/qworker/test/qworkerTests.cpp @@ -56,7 +56,7 @@ uint64_t qwtTestQueryId = 0; bool qwtTestEnableSleep = true; bool qwtTestStop = false; bool qwtTestDeadLoop = false; -int32_t qwtTestMTRunSec = 6000; +int32_t qwtTestMTRunSec = 2; int32_t qwtTestPrintNum = 10000; uint64_t qwtTestCaseIdx = 0; uint64_t qwtTestCaseNum = 4;