diff --git a/src/client/src/tscServer.c b/src/client/src/tscServer.c
index de57f62fbebf408d0b53b7fb76ac53a7e86f1ce2..435a6d7214bedbd1afd11ad2efc5299a7f4520c5 100644
--- a/src/client/src/tscServer.c
+++ b/src/client/src/tscServer.c
@@ -376,7 +376,7 @@ void tscProcessActivityTimer(void *handle, void *tmrId) {
 
   // check queries already death
   static int activetyTimerCnt = 0;
-  if (++activetyTimerCnt > 5) { // 1.5s * 10 = 15s interval call
+  if (++activetyTimerCnt > 3) { // 1.5s * 10 = 15s interval call
     activetyTimerCnt = 0;
 
     // call check if have query doing
diff --git a/src/rpc/src/rpcMain.c b/src/rpc/src/rpcMain.c
index a8cd533e36248df16320003ec28348e2ec394e94..c4c2232e6b18ed97f680384865ddee81848af189 100644
--- a/src/rpc/src/rpcMain.c
+++ b/src/rpc/src/rpcMain.c
@@ -1710,7 +1710,7 @@ bool doRpcSendProbe(SRpcConn *pConn) {
   memcpy(pHead->user, pConn->user, tListLen(pHead->user));
   pHead->code = htonl(code);
 
-  bool ret = rpcSendMsgToPeer(pConn, msg, sizeof(SRpcHead));
+  bool ret = rpcSendMsgToPeer(pConn, msg, sizeof(SRpcHead) + sizeof(int32_t));
   pConn->secured = 1; // connection shall be secured
 
   return ret;
@@ -1778,13 +1778,17 @@ bool rpcSaveSendInfo(int64_t rpcRid, void** ppContext, void** ppConn, void** ppF
     return false;
   }
 
+  if (pContext->pConn == NULL || pContext->pConn->chandle == NULL) {
+    return false;
+  }
+
   if (ppContext)
     *ppContext = pContext;
   if (ppConn)
     *ppConn    = pContext->pConn;
-  if (ppFdObj && pContext->pConn)
+  if (ppFdObj)
     *ppFdObj   = pContext->pConn->chandle;
-  if (pFd && pContext->pConn && pContext->pConn->chandle)
+  if (pFd)
     *pFd       = taosGetFdID(pContext->pConn->chandle);
 
   taosReleaseRef(tsRpcRefId, rpcRid);