diff --git a/src/rpc/src/rpcMain.c b/src/rpc/src/rpcMain.c
index b9602696d6..73ea23cbf8 100755
--- a/src/rpc/src/rpcMain.c
+++ b/src/rpc/src/rpcMain.c
@@ -1097,7 +1097,7 @@ static void rpcProcessConnError(void *param, void *id) {
  
   tTrace("%s connection error happens", pRpc->label);
 
-  if ( pContext->numOfTry >= pContext->ipSet.numOfIps*2 ) {
+  if (pContext->numOfTry >= pContext->ipSet.numOfIps) {
     rpcMsg.msgType = pContext->msgType+1;
     rpcMsg.handle = pContext->ahandle;
     rpcMsg.code = pContext->code;