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

Ensure that the refresh has ran on all shards. 

Original commit: elastic/x-pack-elasticsearch@6214514956
This commit is contained in:
Martijn van Groningen 2014-12-23 16:30:04 +01:00
parent a7e85df649
commit df7fc714e7
2 changed files with 3 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

2
src/main/java/org/elasticsearch/alerts/AlertsStore.java
View File

@ -198,7 +198,7 @@ public class AlertsStore extends AbstractComponent {
private void loadAlerts() { private void loadAlerts() {
assert alertMap.isEmpty() : "No alerts should reside, but there are " + alertMap.size() + " alerts."; assert alertMap.isEmpty() : "No alerts should reside, but there are " + alertMap.size() + " alerts.";
RefreshResponse refreshResponse = client.admin().indices().refresh(new RefreshRequest(ALERT_INDEX)).actionGet(); RefreshResponse refreshResponse = client.admin().indices().refresh(new RefreshRequest(ALERT_INDEX)).actionGet();
if (refreshResponse.getSuccessfulShards() != refreshResponse.getSuccessfulShards()) { if (refreshResponse.getTotalShards() != refreshResponse.getSuccessfulShards()) {
throw new ElasticsearchException("Not all shards have been refreshed"); throw new ElasticsearchException("Not all shards have been refreshed");
} }

4
src/main/java/org/elasticsearch/alerts/actions/AlertActionManager.java
View File

@ -165,10 +165,10 @@ public class AlertActionManager extends AbstractComponent {
return ALERT_HISTORY_INDEX_PREFIX + alertHistoryIndexTimeFormat.print(time); return ALERT_HISTORY_INDEX_PREFIX + alertHistoryIndexTimeFormat.print(time);
} }
public void loadQueue() { private void loadQueue() {
assert actionsToBeProcessed.isEmpty() : "Queue should be empty, but contains " + actionsToBeProcessed.size() + " elements."; assert actionsToBeProcessed.isEmpty() : "Queue should be empty, but contains " + actionsToBeProcessed.size() + " elements.";
RefreshResponse refreshResponse = client.admin().indices().refresh(new RefreshRequest(ALERT_HISTORY_INDEX_PREFIX + "*")).actionGet(); RefreshResponse refreshResponse = client.admin().indices().refresh(new RefreshRequest(ALERT_HISTORY_INDEX_PREFIX + "*")).actionGet();
if (refreshResponse.getSuccessfulShards() != refreshResponse.getSuccessfulShards()) { if (refreshResponse.getTotalShards() != refreshResponse.getSuccessfulShards()) {
throw new ElasticsearchException("Not all shards have been refreshed"); throw new ElasticsearchException("Not all shards have been refreshed");
} }