diff --git a/server/src/internalClusterTest/java/org/opensearch/repositories/RepositoriesServiceIT.java b/server/src/internalClusterTest/java/org/opensearch/repositories/RepositoriesServiceIT.java index 44b286f23fb19..cd0e830e11ef4 100644 --- a/server/src/internalClusterTest/java/org/opensearch/repositories/RepositoriesServiceIT.java +++ b/server/src/internalClusterTest/java/org/opensearch/repositories/RepositoriesServiceIT.java @@ -127,7 +127,6 @@ public void testSystemRepositoryCantBeCreated() { assertThrows(RepositoryException.class, () -> createRepository(repositoryName, FsRepository.TYPE, repoSettings)); } - @AwaitsFix(bugUrl = "https://github.com/opensearch-project/OpenSearch/issues/15842") public void testCreatSnapAndUpdateReposityCauseInfiniteLoop() throws InterruptedException { // create index internalCluster(); @@ -173,16 +172,20 @@ public void testCreatSnapAndUpdateReposityCauseInfiniteLoop() throws Interrupted }); thread.start(); - logger.info("--> begin to reset repository"); - repoSettings = Settings.builder().put("location", randomRepoPath()).put("max_snapshot_bytes_per_sec", "300mb"); - OpenSearchIntegTestCase.putRepositoryWithNoSettingOverrides( - client().admin().cluster(), - repositoryName, - FsRepository.TYPE, - true, - repoSettings - ); - logger.info("--> finish to reset repository"); + try { + logger.info("--> begin to reset repository"); + repoSettings = Settings.builder().put("location", randomRepoPath()).put("max_snapshot_bytes_per_sec", "300mb"); + OpenSearchIntegTestCase.putRepositoryWithNoSettingOverrides( + client().admin().cluster(), + repositoryName, + FsRepository.TYPE, + true, + repoSettings + ); + logger.info("--> finish to reset repository"); + } catch (IllegalStateException e) { + assertThat(e, hasToString(containsString(("trying to modify or unregister repository that is currently used")))); + } // after updating repository, snapshot should be success createSnapshot.run();