honeymoose
/
OpenSearch
mirror of https://github.com/honeymoose/OpenSearch.git
1
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

removed retry start watcher mechanism 

If nodes drop and .watches / .triggered_watches shards are available after those shards were started a new cluster state update will come along that triggers the start watcher logic.

Original commit: elastic/x-pack-elasticsearch@af36f8b078
This commit is contained in:
Martijn van Groningen 2015-06-18 15:48:16 +02:00
parent ca58e93150
commit 7a55a957d3
1 changed files with 5 additions and 23 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

28
src/main/java/org/elasticsearch/watcher/WatcherLifeCycleService.java
View File

@ -78,30 +78,12 @@ public class WatcherLifeCycleService extends AbstractComponent implements Cluste
return; return;
} }
int attempts = 0; logger.trace("starting... (based on cluster state version [{}])", state.getVersion());
for (; attempts < 3; attempts++) { try {
try { watcherService.start(state);
if (logger.isDebugEnabled()) { } catch (Exception e) {
logger.debug("start attempt [{}]...", attempts); logger.debug("failed to start watcher. please wait for the cluster to become ready or try to start Watcher manually");
} else if (logger.isTraceEnabled()) {
logger.trace("starting... (attempt [{}] - based on cluster state version [{}])", attempts, state.getVersion());
}
watcherService.start(state);
return;
} catch (Exception e) {
logger.warn("error occurred while starting, retrying...", e);
try {
Thread.sleep(1000);
} catch (InterruptedException ie) {
Thread.currentThread().interrupt();
}
if (!clusterService.localNode().masterNode()) {
logger.error("abort retry, we are no longer master");
return;
}
}
} }
logger.error("failed to start watcher. attempted to start [{}] times. please try to start Watcher manually", attempts);
} }
@Override @Override