diff --git a/src/main/java/org/elasticsearch/gateway/local/LocalGatewayAllocator.java b/src/main/java/org/elasticsearch/gateway/local/LocalGatewayAllocator.java index 92298d75e7fa8..564fc8e913142 100644 --- a/src/main/java/org/elasticsearch/gateway/local/LocalGatewayAllocator.java +++ b/src/main/java/org/elasticsearch/gateway/local/LocalGatewayAllocator.java @@ -550,6 +550,7 @@ public ClusterState execute(ClusterState currentState) throws Exception { @Override public void onFailure(String source, Throwable t) { + rerouting.set(false); logger.warn("failed to perform reroute post async fetch for {}", t, source); } }); diff --git a/src/test/java/org/elasticsearch/cluster/MinimumMasterNodesTests.java b/src/test/java/org/elasticsearch/cluster/MinimumMasterNodesTests.java index 6f8dc72192f2b..9d645b6d4d63f 100644 --- a/src/test/java/org/elasticsearch/cluster/MinimumMasterNodesTests.java +++ b/src/test/java/org/elasticsearch/cluster/MinimumMasterNodesTests.java @@ -167,7 +167,6 @@ public void run() { @Test @LuceneTestCase.Slow @TestLogging("cluster.routing.allocation.allocator:TRACE") - @LuceneTestCase.AwaitsFix(bugUrl = "boaz is looking into this") public void multipleNodesShutdownNonMasterNodes() throws Exception { Settings settings = settingsBuilder() .put("discovery.type", "zen")