Repository: incubator-unomi Updated Branches: refs/heads/master 3b1615ec0 -> b8ecd0c4d
UNOMI-130 fix issue when update index template Project: http://git-wip-us.apache.org/repos/asf/incubator-unomi/repo Commit: http://git-wip-us.apache.org/repos/asf/incubator-unomi/commit/b8ecd0c4 Tree: http://git-wip-us.apache.org/repos/asf/incubator-unomi/tree/b8ecd0c4 Diff: http://git-wip-us.apache.org/repos/asf/incubator-unomi/diff/b8ecd0c4 Branch: refs/heads/master Commit: b8ecd0c4d31c51377dd47316f8340eb7815dd602 Parents: 3b1615e Author: dgaillard <[email protected]> Authored: Fri Nov 3 18:19:20 2017 +0100 Committer: dgaillard <[email protected]> Committed: Fri Nov 3 18:19:20 2017 +0100 ---------------------------------------------------------------------- .../elasticsearch/ElasticSearchPersistenceServiceImpl.java | 5 ++++- 1 file changed, 4 insertions(+), 1 deletion(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/incubator-unomi/blob/b8ecd0c4/persistence-elasticsearch/core/src/main/java/org/apache/unomi/persistence/elasticsearch/ElasticSearchPersistenceServiceImpl.java ---------------------------------------------------------------------- diff --git a/persistence-elasticsearch/core/src/main/java/org/apache/unomi/persistence/elasticsearch/ElasticSearchPersistenceServiceImpl.java b/persistence-elasticsearch/core/src/main/java/org/apache/unomi/persistence/elasticsearch/ElasticSearchPersistenceServiceImpl.java index 1461c33..1239994 100644 --- a/persistence-elasticsearch/core/src/main/java/org/apache/unomi/persistence/elasticsearch/ElasticSearchPersistenceServiceImpl.java +++ b/persistence-elasticsearch/core/src/main/java/org/apache/unomi/persistence/elasticsearch/ElasticSearchPersistenceServiceImpl.java @@ -1001,7 +1001,10 @@ public class ElasticSearchPersistenceServiceImpl implements PersistenceService, return; } if (itemsMonthlyIndexed.contains(type)) { - createMapping(type, source, indexName + "-*"); + createMonthlyIndexTemplate(); + if (client.admin().indices().prepareExists(indexName + "-*").execute().actionGet().isExists()){ + createMapping(type, source, indexName + "-*"); + } } else if (indexNames.containsKey(type)) { if (client.admin().indices().prepareExists(indexNames.get(type)).execute().actionGet().isExists()) { createMapping(type, source, indexNames.get(type));
