From 9bf875e86115c72f5cbd2d03e835ded9a04f9ff9 Mon Sep 17 00:00:00 2001 From: Jason Tedor Date: Thu, 21 Sep 2017 06:02:50 -0400 Subject: [PATCH] State handling --- core/src/main/java/org/elasticsearch/index/IndexService.java | 5 +++-- 1 file changed, 3 insertions(+), 2 deletions(-) diff --git a/core/src/main/java/org/elasticsearch/index/IndexService.java b/core/src/main/java/org/elasticsearch/index/IndexService.java index 2f9a28e687dfe..c0eca65d5f27f 100644 --- a/core/src/main/java/org/elasticsearch/index/IndexService.java +++ b/core/src/main/java/org/elasticsearch/index/IndexService.java @@ -730,13 +730,14 @@ private void syncGlobalCheckpoints() { for (final IndexShard shard : this.shards.values()) { if (shard.routingEntry().active() && shard.routingEntry().primary()) { switch (shard.state()) { + case CLOSED: case CREATED: case RECOVERING: - case CLOSED: + case RELOCATED: continue; case POST_RECOVERY: + assert false : "shard " + shard.shardId() + " is in post-recovery but marked as active"; case STARTED: - case RELOCATED: try { shard.acquirePrimaryOperationPermit( ActionListener.wrap(