honeymoose/OpenSearch
1
0
Fork 0
mirror of https://github.com/honeymoose/OpenSearch.git synced 2025-03-09 14:34:43 +00:00
Code Issues Packages Projects Releases Wiki Activity

test: change no master block assert and if it fails print which node doesn't have a master block.

Browse Source 
Original commit: elastic/x-pack-elasticsearch@656a1bc3df
This commit is contained in:
Martijn van Groningen 2015-05-07 00:40:16 +02:00
parent e1beb6e9b3
commit 5e7ef773b3
1 changed files with 4 additions and 7 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

11
src/test/java/org/elasticsearch/watcher/test/integration/NoMasterNodeTests.java
View File

@ -220,17 +220,14 @@ public class NoMasterNodeTests extends AbstractWatcherIntegrationTests {
private void stopElectedMasterNodeAndWait() throws Exception {
internalTestCluster().stopCurrentMasterNode();
// Can't use ensureWatcherStopped, b/c that relies on the watcher stats api which requires an elected master node
assertThat(awaitBusy(new Predicate<Object>() {
public boolean apply(Object obj) {
assertBusy(new Runnable() {
public void run () {
for (Client client : clients()) {
ClusterState state = client.admin().cluster().prepareState().setLocal(true).get().getState();
if (!state.blocks().hasGlobalBlock(DiscoverySettings.NO_MASTER_BLOCK_ID)) {
return false;
}
assertThat("Node [" + state.nodes().localNode() + "] should have a NO_MASTER_BLOCK", state.blocks().hasGlobalBlock(DiscoverySettings.NO_MASTER_BLOCK_ID), is(true));
}
return true;
}
}, 30, TimeUnit.SECONDS), equalTo(true));
}, 30, TimeUnit.SECONDS);
// Ensure that the watch manager doesn't run elsewhere
for (WatcherService watcherService : internalTestCluster().getInstances(WatcherService.class)) {
assertThat(watcherService.state(), is(WatcherState.STOPPED));