feature/scheduler

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;
+}

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;