diff --git a/server/src/main/java/org/elasticsearch/index/shard/IndexShard.java b/server/src/main/java/org/elasticsearch/index/shard/IndexShard.java index f29f17a46dcf4..9131055bcd928 100644 --- a/server/src/main/java/org/elasticsearch/index/shard/IndexShard.java +++ b/server/src/main/java/org/elasticsearch/index/shard/IndexShard.java @@ -2229,7 +2229,13 @@ private void bumpPrimaryTerm(long newPrimaryTerm, final Ch onBlocked.run(); } }, - e -> failShard("exception during primary term transition", e)); + e -> { + try { + failShard("exception during primary term transition", e); + } catch (AlreadyClosedException ace) { + // ignore, shard is already closed + } + }); pendingPrimaryTerm = newPrimaryTerm; termUpdated.countDown(); }