Repository: incubator-unomi Updated Branches: refs/heads/feature-UNOMI-28-ES2X fcea70579 -> 62d11ded0
UNOMI-63 Use ElasticSearch BulkProcessing to perform segment updates - Use configured address by default if none is specified in the elasticsearch.yml file. Project: http://git-wip-us.apache.org/repos/asf/incubator-unomi/repo Commit: http://git-wip-us.apache.org/repos/asf/incubator-unomi/commit/62d11ded Tree: http://git-wip-us.apache.org/repos/asf/incubator-unomi/tree/62d11ded Diff: http://git-wip-us.apache.org/repos/asf/incubator-unomi/diff/62d11ded Branch: refs/heads/feature-UNOMI-28-ES2X Commit: 62d11ded05668452731af5ba4ae23e8cd6bb98c2 Parents: fcea705 Author: Serge Huber <[email protected]> Authored: Thu Nov 17 14:29:12 2016 +0100 Committer: Serge Huber <[email protected]> Committed: Thu Nov 17 14:29:12 2016 +0100 ---------------------------------------------------------------------- .../elasticsearch/ElasticSearchPersistenceServiceImpl.java | 6 ++++++ 1 file changed, 6 insertions(+) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/incubator-unomi/blob/62d11ded/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 2915c32..b954b75 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 @@ -143,6 +143,7 @@ public class ElasticSearchPersistenceServiceImpl implements PersistenceService, public static final String BULK_PROCESSOR_BULK_SIZE = "bulkProcessor.bulkSize"; public static final String BULK_PROCESSOR_FLUSH_INTERVAL = "bulkProcessor.flushInterval"; public static final String BULK_PROCESSOR_BACKOFF_POLICY = "bulkProcessor.backoffPolicy"; + public static final String ELASTICSEARCH_NETWORK_HOST = "network.host"; private Node node; private Client client; @@ -349,6 +350,11 @@ public class ElasticSearchPersistenceServiceImpl implements PersistenceService, .put(NODE_CONTEXTSERVER_SECURE_PORT, securePort) .put(INDEX_MAX_RESULT_WINDOW, "2147483647"); + if (settingsBuilder.get(ELASTICSEARCH_NETWORK_HOST) == null) { + logger.info("Setting ElasticSearch network host address to {}", address); + settingsBuilder.put(ELASTICSEARCH_NETWORK_HOST, address); + } + node = nodeBuilder().settings(settingsBuilder).node(); client = node.client(); logger.info("Waiting for ElasticSearch to start...");
