fix: memory leak while taos_query blocked then terminal signal received (#35064)

Author: DuanKuanJun

source/client/src/clientImpl.c

@@ -513,6 +513,11 @@ int32_t asyncExecDdlQuery(SRequestObj* pRequest, SQuery* pQuery) {
   SMsgSendInfo* pSendMsg = buildMsgInfoImpl(pRequest);
 
   int32_t code = asyncSendMsgToServer(pAppInfo->pTransporter, &pMsgInfo->epSet, NULL, pSendMsg);
+  // pMsgInfo->pMsg has been transferred to pRequest->body.requestMsg and pMsgInfo->epSet has
+  // been consumed by asyncSendMsgToServer; the SCmdMsgInfo struct itself is no longer needed.
+  // Free it now so that nodesDestroyAllocatorSet() during atexit does not orphan it when the
+  // chunk containing pQuery is released before doDestroyRequest() can be called.
+  taosMemoryFreeClear(pQuery->pCmdMsg);
   if (code) {
     doRequestCallback(pRequest, code);
   }

source/libs/executor/src/sysscanoperator.c

@@ -4935,7 +4935,7 @@ static SSDataBlock* sysTableScanFromMNode(SOperatorInfo* pOperator, SSysTableSca
              pRsp->numOfRows, pInfo->loadInfo.totalRows);
 
       if (pRsp->numOfRows == 0) {
-        taosMemoryFree(pRsp);
+        taosMemoryFreeClear(pInfo->pRsp);
         return NULL;
       }
     }
@@ -4945,7 +4945,7 @@ static SSDataBlock* sysTableScanFromMNode(SOperatorInfo* pOperator, SSysTableSca
     if (code != TSDB_CODE_SUCCESS) {
       qError("%s failed at line %d since %s", __func__, __LINE__, tstrerror(code));
       pTaskInfo->code = code;
-      taosMemoryFreeClear(pRsp);
+      taosMemoryFreeClear(pInfo->pRsp);
       T_LONG_JMP(pTaskInfo->env, code);
     }
     updateLoadRemoteInfo(&pInfo->loadInfo, pRsp->numOfRows, pRsp->compLen, startTs, pOperator);
@@ -4954,10 +4954,10 @@ static SSDataBlock* sysTableScanFromMNode(SOperatorInfo* pOperator, SSysTableSca
     if (code != TSDB_CODE_SUCCESS) {
       qError("%s failed at line %d since %s", __func__, __LINE__, tstrerror(code));
       pTaskInfo->code = code;
-      taosMemoryFreeClear(pRsp);
+      taosMemoryFreeClear(pInfo->pRsp);
       T_LONG_JMP(pTaskInfo->env, code);
     }
-    taosMemoryFree(pRsp);
+    taosMemoryFreeClear(pInfo->pRsp);
     if (pInfo->pRes->info.rows > 0) {
       return pInfo->pRes;
     } else if (pOperator->status == OP_EXEC_DONE) {

test/cases/18-StreamProcessing/20-UseCase/test_idmp_meters.py

@@ -644,6 +644,7 @@ def trigger_stream5(self):
         # blank 12
         disTs += 12 * step
 
+        time.sleep(5)
         # disorder write 1 rows
         count = 2
         vals = "39,200,200"

test/cases/25-Privileges/test_priv_control.py

@@ -162,7 +162,7 @@ def revoke_role(self, role_name, user_name):
 
     def exec_sql(self, sql):
         # Execute SQL and return success
-        tdSql.execute(sql)
+        tdSql.execute(sql, queryTimes=30)
         print(f"   Executed: {sql}")
 
     def exec_sql_failed(self, sql, errno=None, queryTimes=30):

test/ci/run_upgrade_compat.sh

@@ -96,10 +96,10 @@ function download_version() {
     local start_time
     start_time=$(date +%s)
 
-    # Quick check: skip if cache exists and all files are >= 30M
+    # Quick check: skip if cache exists and all files are >= 10M
     local file_count valid_count
     file_count=$(find "$target_dir" -maxdepth 1 -type f 2>/dev/null | wc -l)
-    valid_count=$(find "$target_dir" -maxdepth 1 -type f -size +30M 2>/dev/null | wc -l)
+    valid_count=$(find "$target_dir" -maxdepth 1 -type f -size +10M 2>/dev/null | wc -l)
     if [ "$file_count" -ge 2 ] && [ "$valid_count" -eq "$file_count" ]; then
         return 0
     fi
@@ -110,7 +110,7 @@ function download_version() {
 
         # Re-check inside lock in case another process already finished
         file_count=$(find "$target_dir" -maxdepth 1 -type f 2>/dev/null | wc -l)
-        valid_count=$(find "$target_dir" -maxdepth 1 -type f -size +30M 2>/dev/null | wc -l)
+        valid_count=$(find "$target_dir" -maxdepth 1 -type f -size +10M 2>/dev/null | wc -l)
         if [ "$file_count" -ge 2 ] && [ "$valid_count" -eq "$file_count" ]; then
             return 0
         fi