diff --git a/core/src/main/java/org/elasticsearch/index/shard/IndexShard.java b/core/src/main/java/org/elasticsearch/index/shard/IndexShard.java index 5e9d078a078..5a764a12077 100644 --- a/core/src/main/java/org/elasticsearch/index/shard/IndexShard.java +++ b/core/src/main/java/org/elasticsearch/index/shard/IndexShard.java @@ -759,13 +759,7 @@ public class IndexShard extends AbstractIndexShardComponent { */ public void failShard(String reason, @Nullable Throwable e) { // fail the engine. This will cause this shard to also be removed from the node's index service. - final Engine engine = getEngineOrNull(); - if (engine == null) { - logger.trace("ignoring request to fail the shard, we're already closed. (reason: [{}])", e, reason); - - } else { - engine.failEngine(reason, e); - } + getEngine().failEngine(reason, e); } public Engine.Searcher acquireSearcher(String source) {