diff --git a/modules/elasticsearch/src/main/java/org/elasticsearch/index/analysis/AnalysisService.java b/modules/elasticsearch/src/main/java/org/elasticsearch/index/analysis/AnalysisService.java index 6cb4bac8c55..247c923e516 100644 --- a/modules/elasticsearch/src/main/java/org/elasticsearch/index/analysis/AnalysisService.java +++ b/modules/elasticsearch/src/main/java/org/elasticsearch/index/analysis/AnalysisService.java @@ -160,7 +160,14 @@ public class AnalysisService extends AbstractIndexComponent implements Closeable public void close() { for (NamedAnalyzer analyzer : analyzers.values()) { if (analyzer.scope() == AnalyzerScope.INDEX) { - analyzer.close(); + try { + analyzer.close(); + } catch (NullPointerException e) { + // because analyzers are aliased, they might be closed several times + // an NPE is thrown in this case, so ignore.... + } catch (Exception e) { + logger.debug("failed to close analyzer " + analyzer); + } } } } diff --git a/modules/elasticsearch/src/main/java/org/elasticsearch/indices/cluster/IndicesClusterStateService.java b/modules/elasticsearch/src/main/java/org/elasticsearch/indices/cluster/IndicesClusterStateService.java index 069a1c74d6a..3b2b1c61706 100644 --- a/modules/elasticsearch/src/main/java/org/elasticsearch/indices/cluster/IndicesClusterStateService.java +++ b/modules/elasticsearch/src/main/java/org/elasticsearch/indices/cluster/IndicesClusterStateService.java @@ -134,7 +134,11 @@ public class IndicesClusterStateService extends AbstractLifecycleComponent