[Store] migrate non-allocated shard deletion to use ClusterStateNonMasterUpdateTask

2014-07-17 15:55:03 +02:00 · 2014-07-17 15:55:03 +02:00 · f029a24d53
parent bebaf9799c
commit f029a24d53
1 changed files with 1 additions and 1 deletions
--- a/src/main/java/org/elasticsearch/indices/store/IndicesStore.java
+++ b/src/main/java/org/elasticsearch/indices/store/IndicesStore.java
@ -307,7 +307,7 @@ public class IndicesStore extends AbstractComponent implements ClusterStateListe
                return;
            }

-            clusterService.submitStateUpdateTask("indices_store", new ClusterStateUpdateTask() {
+            clusterService.submitStateUpdateTask("indices_store", new ClusterStateNonMasterUpdateTask() {
                @Override
                public ClusterState execute(ClusterState currentState) throws Exception {
                    if (clusterState.getVersion() != currentState.getVersion()) {