remove try in posIndex

2015-09-02 18:04:26 +05:00 · 2015-09-02 18:04:26 +05:00 · 30b6a29e0b
parent 32b304b43c
commit 30b6a29e0b
1 changed files with 1 additions and 5 deletions
--- 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);
        }
    }