fix tmq crash issue

source/client/src/clientImpl.c

@@ -727,8 +727,10 @@ void launchAsyncQuery(SRequestObj* pRequest, SQuery* pQuery) {
 
       if (TSDB_CODE_SUCCESS == code) {
         code = qCreateQueryPlan(&cxt, &pRequest->body.pDag, pNodeList);
+        if (code) {
           tscError("0x%"PRIx64" failed to create query plan, code:%s 0x%"PRIx64, pRequest->self, tstrerror(code), pRequest->requestId);
         }
+      }
 
       if (TSDB_CODE_SUCCESS == code) {
         SRequestConnInfo conn = {.pTrans = pAppInfo->pTransporter, 

source/client/src/tmq.c

@@ -1162,7 +1162,7 @@ int32_t tmqPollImpl(tmq_t* tmq, int64_t timeout) {
       pParam->vgId = pVg->vgId;
       pParam->epoch = tmq->epoch;
 
-      SMsgSendInfo* sendInfo = taosMemoryMalloc(sizeof(SMsgSendInfo));
+      SMsgSendInfo* sendInfo = taosMemoryCalloc(1, sizeof(SMsgSendInfo));
       if (sendInfo == NULL) {
         taosMemoryFree(pReq);
         taosMemoryFree(pParam);

source/dnode/mnode/impl/inc/mndDef.h

@@ -334,6 +334,7 @@ typedef struct {
   int64_t  dbUid;
   int32_t  tagVer;
   int32_t  colVer;
+  int32_t  smaVer;
   int32_t  nextColId;
   float    xFilesFactor;
   int32_t  delay;

source/libs/scheduler/src/schJob.c

@@ -1514,7 +1514,7 @@ int32_t schExecJob(SSchedulerReq *pReq, int64_t *pJob, SQueryResult *pRes) {
   if (EXPLAIN_MODE_STATIC == pReq->pDag->explainInfo.mode) {
     SCH_ERR_JRET(schExecStaticExplainJob(pReq, pJob, true));
   } else {
-    SCH_ERR_JRET(schExecJobImpl(pReq, pJob, pRes, true));
+    SCH_ERR_JRET(schExecJobImpl(pReq, pJob, NULL, true));
   }
 
 _return:

tests/test/c/tmqSim.c

@@ -490,6 +490,7 @@ void* consumeThreadFunc(void* param) {
   build_consumer(pInfo);
   build_topic_list(pInfo);
   if ((NULL == pInfo->tmq) || (NULL == pInfo->topicList)) {
+    assert(0);
     return NULL;
   }