@@ -362,23 +362,24 @@ private List<MachineAndPorts> buildMachinePortsMap(String clusterName, List<Mach
362362 int avgNodeNumber = nodeNumber / machineList .size ();
363363 avgNodeNumber = nodeNumber % machineList .size () == 0 ? avgNodeNumber : avgNodeNumber + 1 ;
364364 for (Machine machine : machineList ) {
365+ int currentPort = port ;
365366 List <Integer > ports = new ArrayList <>();
366367 String host = machine .getHost ();
367368 while (avgNodeNumber > ports .size () && getPortNumber (machineAndPortsList ) < nodeNumber ) {
368- if (port >= MAX_PORT ) {
369+ if (currentPort >= MAX_PORT ) {
369370 break ;
370371 }
371372 try {
372- if (!NetworkUtil .telnet (host , port )) {
373- ports .add (port );
373+ if (!NetworkUtil .telnet (host , currentPort )) {
374+ ports .add (currentPort );
374375 }
375376 } catch (Exception e ) {
376- String message = "Check port failed, host: " + host + ", port: " + port ;
377+ String message = "Check port failed, host: " + host + ", port: " + currentPort ;
377378 InstallationWebSocketHandler .appendLog (clusterName , message );
378379 InstallationWebSocketHandler .appendLog (clusterName , e .getMessage ());
379380 logger .error (message , e );
380381 }
381- port ++;
382+ currentPort ++;
382383 }
383384 machineAndPortsList .add (new MachineAndPorts (machine , ports ));
384385 }
@@ -578,11 +579,10 @@ private String updateRedisPassword(String redisPassword, Cluster cluster) {
578579 redisClient = RedisClientFactory .buildRedisClient (redisNode , redisPassword );
579580 redisClient .rewriteConfig ();
580581 redisClient .close ();
581-
582582 } catch (Exception e ) {
583583 String message = "Update redis password failed, host=" + redisNode .getHost () + ", port=" + redisNode .getPort () + "." ;
584584 logger .error (message , e );
585- result .append (message + e .getMessage ());
585+ result .append (message ). append ( e .getMessage ());
586586 }
587587 });
588588 if (Strings .isNullOrEmpty (result .toString ())) {
0 commit comments