optimize the validation checks for restore flow

Signed-off-by: bansvaru <[email protected]>
opensearch-project · Sep 6, 2023 · 5f89bbc · 5f89bbc
1 parent 207ae90
commit 5f89bbc
Showing 1 changed file with 13 additions and 14 deletions.
diff --git a/server/src/main/java/org/opensearch/index/recovery/RemoteStoreRestoreService.java b/server/src/main/java/org/opensearch/index/recovery/RemoteStoreRestoreService.java
@@ -249,19 +249,6 @@ private void validate(
     ) throws IllegalStateException, IllegalArgumentException {
         String errorMsg = "cannot restore index [%s] because an open index with same name/uuid already exists in the cluster.";
 
-        Set<String> graveyardIndexNames = new HashSet<>();
-        Set<String> graveyardIndexUUID = new HashSet<>();
-        Set<String> liveClusterIndexUUIDs = currentState.metadata()
-            .indices()
-            .values()
-            .stream()
-            .map(IndexMetadata::getIndexUUID)
-            .collect(Collectors.toSet());
-
-        currentState.metadata().indexGraveyard().getTombstones().forEach(tombstone -> {
-            graveyardIndexNames.add(tombstone.getIndex().getName());
-            graveyardIndexUUID.add(tombstone.getIndex().getUUID());
-        });
         // Restore with current cluster UUID will fail as same indices would be present in the cluster which we are trying to
         // restore
         if (currentState.metadata().clusterUUID().equals(restoreClusterUUID)) {
@@ -274,6 +261,19 @@ private void validate(
             boolean metadataFromRemoteStore = indexMetadataEntry.getValue().v1();
             if (indexMetadata.getSettings().getAsBoolean(SETTING_REMOTE_STORE_ENABLED, false)) {
                 if (metadataFromRemoteStore) {
+                    Set<String> graveyardIndexNames = new HashSet<>();
+                    Set<String> graveyardIndexUUID = new HashSet<>();
+                    Set<String> liveClusterIndexUUIDs = currentState.metadata()
+                        .indices()
+                        .values()
+                        .stream()
+                        .map(IndexMetadata::getIndexUUID)
+                        .collect(Collectors.toSet());
+
+                    currentState.metadata().indexGraveyard().getTombstones().forEach(tombstone -> {
+                        graveyardIndexNames.add(tombstone.getIndex().getName());
+                        graveyardIndexUUID.add(tombstone.getIndex().getUUID());
+                    });
 
                     // Since updates to graveyard are synced to remote we should neven land in a situation where remote contain index
                     // metadata for graveyard index.
@@ -303,7 +303,6 @@ private void validate(
                     boolean isHidden = IndexMetadata.INDEX_HIDDEN_SETTING.get(indexMetadata.getSettings());
                     createIndexService.validateIndexName(indexName, currentState);
                     createIndexService.validateDotIndex(indexName, isHidden);
-                    createIndexService.validateIndexSettings(indexName, indexMetadata.getSettings(), false);
                     shardLimitValidator.validateShardLimit(indexName, indexMetadata.getSettings(), currentState);
                 } else if (restoreAllShards && IndexMetadata.State.CLOSE.equals(indexMetadata.getState()) == false) {
                     throw new IllegalStateException(String.format(Locale.ROOT, errorMsg, indexName) + " Close the existing index.");