From f029a24d53f3881724f9297e372b4120f1692179 Mon Sep 17 00:00:00 2001 From: Boaz Leskes Date: Thu, 17 Jul 2014 15:55:03 +0200 Subject: [PATCH] [Store] migrate non-allocated shard deletion to use ClusterStateNonMasterUpdateTask --- src/main/java/org/elasticsearch/indices/store/IndicesStore.java | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/src/main/java/org/elasticsearch/indices/store/IndicesStore.java b/src/main/java/org/elasticsearch/indices/store/IndicesStore.java index 02420d0e3d5..ecf5e6b6b22 100644 --- 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()) {