fix tests

Signed-off-by: bansvaru <bansvaru@amazon.com>
opensearch-project · Sep 13, 2023 · a0f4a86 · a0f4a86
1 parent a50d1d2
commit a0f4a86
Showing 1 changed file with 3 additions and 3 deletions.
diff --git a/server/src/main/java/org/opensearch/gateway/remote/RemoteClusterStateService.java b/server/src/main/java/org/opensearch/gateway/remote/RemoteClusterStateService.java
@@ -587,7 +587,7 @@ public Optional<ClusterMetadataManifest> getLatestClusterMetadataManifest(String
      */
     public String getLastKnownUUIDFromRemote(String clusterName) {
         try {
-            Set<String> clusterUUIDs = Collections.unmodifiableSet(getAllClusterUUIDs(clusterName));
+            Set<String> clusterUUIDs = getAllClusterUUIDs(clusterName);
             Map<String, ClusterMetadataManifest> latestManifests = getLatestManifestForAllClusterUUIDs(clusterName, clusterUUIDs);
             List<String> validChain = createClusterChain(latestManifests);
             if (validChain.isEmpty()) {
@@ -606,7 +606,7 @@ private Set<String> getAllClusterUUIDs(String clusterName) throws IOException {
         if (clusterUUIDMetadata == null) {
             return Collections.emptySet();
         }
-        return clusterUUIDMetadata.keySet();
+        return Collections.unmodifiableSet(clusterUUIDMetadata.keySet());
     }
 
     private Map<String, ClusterMetadataManifest> getLatestManifestForAllClusterUUIDs(String clusterName, Set<String> clusterUUIDs) {
@@ -756,7 +756,7 @@ public void deleteStaleClusterUUID(ClusterState clusterState, ClusterMetadataMan
             String clusterName = clusterState.getClusterName().value();
             Set<String> allClustersUUIDsInRemote = null;
             try {
-                allClustersUUIDsInRemote = getAllClusterUUIDs(clusterState.getClusterName().value());
+                allClustersUUIDsInRemote = new HashSet<>(getAllClusterUUIDs(clusterState.getClusterName().value()));
             } catch (IOException e) {
                 throw new RuntimeException(e);
             }