pr comment: nitpick

Signed-off-by: Rishabh Maurya <[email protected]>

Author: rishabhmaurya

server/src/main/java/org/opensearch/cluster/node/DiscoveryNode.java

@@ -136,7 +136,7 @@ public static boolean isDedicatedWarmNode(Settings settings) {
     private final String hostName;
     private final String hostAddress;
     private final TransportAddress address;
-    private TransportAddress streamAddress;
+    private final TransportAddress streamAddress;
     private final Map<String, String> attributes;
     private final Version version;
     private final SortedSet<DiscoveryNodeRole> roles;

server/src/main/java/org/opensearch/cluster/service/ClusterApplierService.java

@@ -618,19 +618,19 @@ private void applyChanges(UpdateTask task, ClusterState previousClusterState, Cl
 
     protected void connectToNodesAndWait(ClusterState newClusterState) {
         // can't wait for an ActionFuture on the cluster applier thread, but we do want to block the thread here, so use a CountDownLatch.
-        CountDownLatch countDownLatch = new CountDownLatch(1);
+        final CountDownLatch countDownLatch = new CountDownLatch(1);
         nodeConnectionsService.connectToNodes(newClusterState.nodes(), countDownLatch::countDown);
         try {
             countDownLatch.await();
         } catch (InterruptedException e) {
             logger.debug("interrupted while connecting to nodes, continuing", e);
             Thread.currentThread().interrupt();
         }
-        countDownLatch = new CountDownLatch(1);
+        final CountDownLatch streamNodeLatch = new CountDownLatch(1);
         if (streamNodeConnectionsService != null) {
-            streamNodeConnectionsService.connectToNodes(newClusterState.nodes(), countDownLatch::countDown);
+            streamNodeConnectionsService.connectToNodes(newClusterState.nodes(), streamNodeLatch::countDown);
             try {
-                countDownLatch.await();
+                streamNodeLatch.await();
             } catch (InterruptedException e) {
                 logger.debug("interrupted while connecting to nodes, continuing", e);
                 Thread.currentThread().interrupt();