You are viewing a plain text version of this content. The canonical link for it is here.
Posted to dev@unomi.apache.org by sh...@apache.org on 2016/11/17 13:29:19 UTC
incubator-unomi git commit: UNOMI-63 Use ElasticSearch BulkProcessing
to perform segment updates - Use configured address by default if none is
specified in the elasticsearch.yml file.
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 <sh...@apache.org>
Authored: Thu Nov 17 14:29:12 2016 +0100
Committer: Serge Huber <sh...@apache.org>
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...");