From bd52d61d5db256dfd4632772544a5dbb9e0ccaa8 Mon Sep 17 00:00:00 2001 From: Shay Banon Date: Sun, 21 Jul 2013 15:21:22 +0200 Subject: [PATCH] reroute post shard started should have HIGH prio as well --- .../elasticsearch/cluster/action/shard/ShardStateAction.java | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/src/main/java/org/elasticsearch/cluster/action/shard/ShardStateAction.java b/src/main/java/org/elasticsearch/cluster/action/shard/ShardStateAction.java index edb9f3838b0..caec7478aa8 100644 --- a/src/main/java/org/elasticsearch/cluster/action/shard/ShardStateAction.java +++ b/src/main/java/org/elasticsearch/cluster/action/shard/ShardStateAction.java @@ -196,7 +196,7 @@ public class ShardStateAction extends AbstractComponent { @Override public void clusterStateProcessed(ClusterState clusterState) { rerouteRequired.set(true); - clusterService.submitStateUpdateTask("reroute post shard-started (" + shardRouting + "), reason [" + reason + "]", new ClusterStateUpdateTask() { + clusterService.submitStateUpdateTask("reroute post shard-started (" + shardRouting + "), reason [" + reason + "]", Priority.HIGH, new ClusterStateUpdateTask() { @Override public ClusterState execute(ClusterState currentState) { if (rerouteRequired.compareAndSet(true, false)) {