|
|
@ -125,9 +125,9 @@ public class TransportClientHelper {
|
|
|
|
.put("cluster.name", settings.get("cluster.name", "elasticsearch"))
|
|
|
|
.put("cluster.name", settings.get("cluster.name", "elasticsearch"))
|
|
|
|
.put("path.home", settings.get("path.home", "."))
|
|
|
|
.put("path.home", settings.get("path.home", "."))
|
|
|
|
.put("processors", settings.getAsInt("processors", Runtime.getRuntime().availableProcessors())) // for thread pool size
|
|
|
|
.put("processors", settings.getAsInt("processors", Runtime.getRuntime().availableProcessors())) // for thread pool size
|
|
|
|
.put("client.transport.sniff", false) // do not sniff
|
|
|
|
.put("client.transport.sniff", false) // always disable sniff
|
|
|
|
.put("client.transport.nodes_sampler_interval", "1m") // do not ping
|
|
|
|
.put("client.transport.nodes_sampler_interval", -1) // do not ping, default is 5 seconds
|
|
|
|
.put("client.transport.ping_timeout", "1m") // wait for unresponsive nodes a very long time before disconnect
|
|
|
|
.put("client.transport.ping_timeout", -1) // disable ping unresponsive nodes, defauult is 5 seconds
|
|
|
|
.put("client.transport.ignore_cluster_name", true) // connect to any cluster
|
|
|
|
.put("client.transport.ignore_cluster_name", true) // connect to any cluster
|
|
|
|
.build();
|
|
|
|
.build();
|
|
|
|
}
|
|
|
|
}
|
|
|
|