Address review comments 2

Signed-off-by: Suraj Singh <[email protected]>
opensearch-project · Sep 16, 2022 · 186a671 · 186a671
1 parent 437aa13
commit 186a671
Showing 1 changed file with 0 additions and 13 deletions.
diff --git a/...r/src/internalClusterTest/java/org/opensearch/snapshots/SegmentReplicationSnapshotIT.java b/...r/src/internalClusterTest/java/org/opensearch/snapshots/SegmentReplicationSnapshotIT.java
@@ -116,10 +116,8 @@ public List<String> startClusterWithSettings(Settings indexSettings, int replica
     public void createSnapshot() {
         // Snapshot declaration
         Path absolutePath = randomRepoPath().toAbsolutePath();
-        logger.info("Path [{}]", absolutePath);
         // Create snapshot
         createRepository(REPOSITORY_NAME, "fs", absolutePath);
-        logger.info("Perform snapshot");
         CreateSnapshotResponse createSnapshotResponse = client().admin()
             .cluster()
             .prepareCreateSnapshot(REPOSITORY_NAME, SNAPSHOT_NAME)
@@ -154,12 +152,10 @@ public void testRestoreOnSegRep() throws Exception {
         assertAcked(client().admin().indices().delete(new DeleteIndexRequest(INDEX_NAME)).get());
         assertFalse("index [" + INDEX_NAME + "] should have been deleted", indexExists(INDEX_NAME));
 
-        logger.info("Restore from snapshot");
         RestoreSnapshotResponse restoreSnapshotResponse = restoreSnapshotWithSettings(null);
 
         // Assertions
         assertThat(restoreSnapshotResponse.status(), equalTo(RestStatus.ACCEPTED));
-        logger.info("Ensure cluster is green");
         ensureGreen(RESTORED_INDEX_NAME);
         GetSettingsResponse settingsResponse = client().admin()
             .indices()
@@ -177,12 +173,10 @@ public void testSnapshotOnSegRep_RestoreOnSegRepDuringIngestion() throws Excepti
         assertAcked(client().admin().indices().delete(new DeleteIndexRequest(INDEX_NAME)).get());
         assertFalse("index [" + INDEX_NAME + "] should have been deleted", indexExists(INDEX_NAME));
 
-        logger.info("Restore from snapshot");
         RestoreSnapshotResponse restoreSnapshotResponse = restoreSnapshotWithSettings(null);
 
         // Assertions
         assertThat(restoreSnapshotResponse.status(), equalTo(RestStatus.ACCEPTED));
-        logger.info("Ensure cluster is green");
         ingestData(5000, RESTORED_INDEX_NAME);
         ensureGreen(RESTORED_INDEX_NAME);
         GetSettingsResponse settingsResponse = client().admin()
@@ -200,12 +194,10 @@ public void testSnapshotOnDocRep_RestoreOnSegRep() throws Exception {
         // Delete index
         assertAcked(client().admin().indices().delete(new DeleteIndexRequest(INDEX_NAME)).get());
 
-        logger.info("Restore from snapshot");
         RestoreSnapshotResponse restoreSnapshotResponse = restoreSnapshotWithSettings(restoreIndexSegRepSettings());
 
         // Assertions
         assertThat(restoreSnapshotResponse.status(), equalTo(RestStatus.ACCEPTED));
-        logger.info("Ensure cluster is green");
         ensureGreen(RESTORED_INDEX_NAME);
         GetSettingsResponse settingsResponse = client().admin()
             .indices()
@@ -224,12 +216,10 @@ public void testSnapshotOnSegRep_RestoreOnDocRep() throws Exception {
         // Delete index
         assertAcked(client().admin().indices().delete(new DeleteIndexRequest(INDEX_NAME)).get());
 
-        logger.info("Restore from snapshot");
         RestoreSnapshotResponse restoreSnapshotResponse = restoreSnapshotWithSettings(restoreIndexDocRepSettings());
 
         // Assertions
         assertThat(restoreSnapshotResponse.status(), equalTo(RestStatus.ACCEPTED));
-        logger.info("Wait for green index health");
         ensureGreen(RESTORED_INDEX_NAME);
         GetSettingsResponse settingsResponse = client().admin()
             .indices()
@@ -246,12 +236,10 @@ public void testSnapshotOnDocRep_RestoreOnDocRep() throws Exception {
         // Delete index
         assertAcked(client().admin().indices().delete(new DeleteIndexRequest(INDEX_NAME)).get());
 
-        logger.info("Restore from snapshot");
         RestoreSnapshotResponse restoreSnapshotResponse = restoreSnapshotWithSettings(restoreIndexDocRepSettings());
 
         // Assertions
         assertThat(restoreSnapshotResponse.status(), equalTo(RestStatus.ACCEPTED));
-        logger.info("Ensure cluster is green");
         ensureGreen(RESTORED_INDEX_NAME);
         GetSettingsResponse settingsResponse = client().admin()
             .indices()
@@ -278,7 +266,6 @@ public void testRestoreOnReplicaNode() throws Exception {
 
         // Assertions
         assertThat(restoreSnapshotResponse.status(), equalTo(RestStatus.ACCEPTED));
-        logger.info("Ensure cluster is green");
         internalCluster().startNode();
         ensureGreen(RESTORED_INDEX_NAME);
         GetSettingsResponse settingsResponse = client().admin()