diff --git a/core/src/main/java/org/elasticsearch/index/indexing/ShardIndexingService.java b/core/src/main/java/org/elasticsearch/index/indexing/ShardIndexingService.java index c7b06f8bcb3..b35f6f9284d 100644 --- a/core/src/main/java/org/elasticsearch/index/indexing/ShardIndexingService.java +++ b/core/src/main/java/org/elasticsearch/index/indexing/ShardIndexingService.java @@ -159,11 +159,7 @@ public class ShardIndexingService extends AbstractIndexShardComponent { totalStats.indexCurrent.dec(); typeStats(index.type()).indexCurrent.dec(); for (IndexingOperationListener listener : listeners) { - try { - listener.postIndex(index, ex); - } catch (Exception e) { - logger.warn("postIndex listener [{}] failed", e, listener); - } + listener.postIndex(index, ex); } }