Update JoinTaskExecutor.java, minor update

Signed-off-by: shwetathareja <[email protected]> Signed-off-by: Rajiv Kumar Vaidyanathan <[email protected]>
rajiv-kv · Oct 28, 2024 · 158d68c · 158d68c
1 parent 6c466e6
commit 158d68c
Showing 1 changed file with 6 additions and 6 deletions.
diff --git a/server/src/main/java/org/opensearch/cluster/coordination/JoinTaskExecutor.java b/server/src/main/java/org/opensearch/cluster/coordination/JoinTaskExecutor.java
@@ -192,22 +192,22 @@ public ClusterTasksResult<Task> execute(ClusterState currentState, List<Task> jo
             .stream()
             .filter(DiscoveryNode::isRemoteStatePublicationEnabled)
             .findFirst();
-        RepositoriesMetadata existingrepositoriesMetadata = currentState.getMetadata().custom(RepositoriesMetadata.TYPE);
+        RepositoriesMetadata existingRepositoriesMetadata = currentState.getMetadata().custom(RepositoriesMetadata.TYPE);
         Map<String, RepositoryMetadata> repositories = new LinkedHashMap<>();
-        if (existingrepositoriesMetadata != null) {
-            existingrepositoriesMetadata.repositories().forEach(r -> repositories.putIfAbsent(r.name(), r));
+        if (existingRepositoriesMetadata != null) {
+            existingRepositoriesMetadata.repositories().forEach(r -> repositories.putIfAbsent(r.name(), r));
         }
         if (remoteDN.isPresent()) {
             RepositoriesMetadata repositoriesMetadata = remoteStoreNodeService.updateRepositoriesMetadata(
                 remoteDN.get(),
-                existingrepositoriesMetadata
+                existingRepositoriesMetadata
             );
             repositoriesMetadata.repositories().forEach(r -> repositories.putIfAbsent(r.name(), r));
         }
         if (remotePublicationDN.isPresent()) {
             RepositoriesMetadata repositoriesMetadata = remoteStoreNodeService.updateRepositoriesMetadata(
                 remotePublicationDN.get(),
-                existingrepositoriesMetadata
+                existingRepositoriesMetadata
             );
             repositoriesMetadata.repositories().forEach(r -> repositories.putIfAbsent(r.name(), r));
         }
@@ -246,7 +246,7 @@ public ClusterTasksResult<Task> execute(ClusterState currentState, List<Task> jo
                         logger.info("Updating system repository now for remote store");
                         RepositoriesMetadata repositoriesMetadata = remoteStoreNodeService.updateRepositoriesMetadata(
                             node,
-                            existingrepositoriesMetadata
+                            existingRepositoriesMetadata
                         );
                         repositoriesMetadata.repositories().forEach(r -> repositories.putIfAbsent(r.name(), r));
                     }