From 647a975dd52a566504cf0f78b6020be1d335ac48 Mon Sep 17 00:00:00 2001 From: Henning Andersen Date: Wed, 18 Aug 2021 13:58:14 +0200 Subject: [PATCH] Fix testRecoveryIsCancelledAfterDeletingTheIndex Closes #76560 --- .../recovery/SnapshotBasedIndexRecoveryIT.java | 12 ++++++------ 1 file changed, 6 insertions(+), 6 deletions(-) diff --git a/server/src/internalClusterTest/java/org/elasticsearch/indices/recovery/SnapshotBasedIndexRecoveryIT.java b/server/src/internalClusterTest/java/org/elasticsearch/indices/recovery/SnapshotBasedIndexRecoveryIT.java index 45784dcfe43e7..4d5bf8cd0d01e 100644 --- a/server/src/internalClusterTest/java/org/elasticsearch/indices/recovery/SnapshotBasedIndexRecoveryIT.java +++ b/server/src/internalClusterTest/java/org/elasticsearch/indices/recovery/SnapshotBasedIndexRecoveryIT.java @@ -475,12 +475,6 @@ public void testRecoveryIsCancelledAfterDeletingTheIndex() throws Exception { createSnapshot(repoName, "snap", Collections.singletonList(indexName)); String targetNode = internalCluster().startDataOnlyNode(); - assertAcked( - client().admin().indices().prepareUpdateSettings(indexName) - .setSettings(Settings.builder() - .put("index.routing.allocation.require._name", targetNode)).get() - ); - MockTransportService targetMockTransportService = (MockTransportService) internalCluster().getInstance(TransportService.class, targetNode); @@ -496,6 +490,12 @@ public void testRecoveryIsCancelledAfterDeletingTheIndex() throws Exception { } ); + assertAcked( + client().admin().indices().prepareUpdateSettings(indexName) + .setSettings(Settings.builder() + .put("index.routing.allocation.require._name", targetNode)).get() + ); + recoverSnapshotFileRequestReceived.await(); assertAcked(client().admin().indices().prepareDelete(indexName).get());