feat(rpc): check valid in broken callback

src/client/src/tscServer.c

@@ -369,8 +369,7 @@ void checkBrokenQueries(STscObj *pTscObj) {
 
     // kill query
     if(kill) {
-      //taos_stop_query(pSql);
-      tscInfo("PROBE do not kill.");
+      taos_stop_query(pSql);
     }
     
     // move next
@@ -401,7 +400,7 @@ void tscProcessActivityTimer(void *handle, void *tmrId) {
     // call check if have query doing
     if(pObj->sqlList) {
       // have queries executing
-      //checkBrokenQueries(pObj);
+      checkBrokenQueries(pObj);
     }
   }
 

src/client/src/tscSubquery.c

@@ -3391,6 +3391,10 @@ static void doFreeInsertSupporter(SSqlObj* pSqlObj) {
 }
 
 static void multiVnodeInsertFinalize(void* param, TAOS_RES* tres, int numOfRows) {
+  if(param == NULL) {
+    tscError("callback multiVnodeInsertFinalize param is NULL. tres=0x%" PRIx64 " numOfRows=%d", tres, numOfRows);
+    return ;
+  }
   SInsertSupporter *pSupporter = (SInsertSupporter *)param;
   SSqlObj* pParentObj = pSupporter->pSql;