diff --git a/elasticsearch/README.md b/elasticsearch/README.md index 9140c576f5589d09060d04fc2f8cf6550b56d0a1..157ccec0c04fe4688da30af531b5fbdc3db4703d 100644 --- a/elasticsearch/README.md +++ b/elasticsearch/README.md @@ -42,7 +42,7 @@ For further configuration see below: ### Defaults Configuration The default setting for the Elasticsearch node that is created is as follows: - es.cluster.name=es.ycsb.cluster + cluster.name=es.ycsb.cluster es.index.key=es.ycsb es.number_of_shards=1 es.number_of_replicas=0 diff --git a/elasticsearch/src/main/java/com/yahoo/ycsb/db/ElasticsearchClient.java b/elasticsearch/src/main/java/com/yahoo/ycsb/db/ElasticsearchClient.java index c30fb65a067b4c0ef5af61584bdae6d6dad09d40..1feb0d58168d521d14fdf9bb8b204e9670aab092 100644 --- a/elasticsearch/src/main/java/com/yahoo/ycsb/db/ElasticsearchClient.java +++ b/elasticsearch/src/main/java/com/yahoo/ycsb/db/ElasticsearchClient.java @@ -57,7 +57,7 @@ import java.util.Vector; * Default properties to set: * </p> * <ul> - * <li>es.cluster.name = es.ycsb.cluster + * <li>cluster.name = es.ycsb.cluster * <li>es.index.key = es.ycsb * <li>es.number_of_shards = 1 * <li>es.number_of_replicas = 0 @@ -83,7 +83,6 @@ public class ElasticsearchClient extends DB { public void init() throws DBException { Properties props = getProperties(); this.indexKey = props.getProperty("es.index.key", DEFAULT_INDEX_KEY); - String clusterName = props.getProperty("es.cluster.name", DEFAULT_CLUSTER_NAME); int numberOfShards = parseIntegerProperty(props, "es.number_of_shards", NUMBER_OF_SHARDS); int numberOfReplicas = parseIntegerProperty(props, "es.number_of_replicas", NUMBER_OF_REPLICAS); @@ -93,14 +92,15 @@ public class ElasticsearchClient extends DB { remoteMode = Boolean.parseBoolean(props.getProperty("es.remote", "false")); Boolean newdb = Boolean.parseBoolean(props.getProperty("es.newdb", "false")); Builder settings = Settings.settingsBuilder() - .put("cluster.name", clusterName) + .put("cluster.name", DEFAULT_CLUSTER_NAME) .put("node.local", Boolean.toString(!remoteMode)) .put("path.home", System.getProperty("java.io.tmpdir")); // if properties file contains elasticsearch user defined properties // add it to the settings file (will overwrite the defaults). settings.put(props); - System.out.println("Elasticsearch starting node = " + settings.get("cluster.name")); + final String clusterName = settings.get("cluster.name"); + System.out.println("Elasticsearch starting node = " + clusterName); System.out.println("Elasticsearch node path.home = " + settings.get("path.home")); System.out.println("Elasticsearch Remote Mode = " + remoteMode); // Remote mode support for connecting to remote elasticsearch cluster