lib/elasticsearch/extensions/test/cluster.rb in elasticsearch-extensions-0.0.14 vs lib/elasticsearch/extensions/test/cluster.rb in elasticsearch-extensions-0.0.15
- old
+ new
@@ -92,22 +92,23 @@
@@number_of_nodes.times do |n|
n += 1
pid = Process.spawn <<-COMMAND
#{arguments[:command]} \
- -f \
-D es.foreground=yes \
-D es.cluster.name=#{arguments[:cluster_name]} \
-D es.node.name=#{arguments[:node_name]}-#{n} \
-D es.http.port=#{arguments[:port].to_i + (n-1)} \
-D es.gateway.type=#{arguments[:gateway_type]} \
-D es.index.store.type=#{arguments[:index_store]} \
-D es.path.data=#{arguments[:path_data]} \
-D es.path.work=#{arguments[:path_work]} \
-D es.network.host=0.0.0.0 \
-D es.discovery.zen.ping.multicast.enabled=true \
+ -D es.script.disable_dynamic=false \
-D es.node.test=true \
+ -D es.node.bench=true \
#{arguments[:es_params]} \
> /dev/null
COMMAND
Process.detach pid
pids << pid
@@ -240,10 +241,10 @@
#
# @api private
#
def __print_cluster_info(port)
health = JSON.parse(Net::HTTP.get(URI("http://localhost:#{port}/_cluster/health")))
- nodes = JSON.parse(Net::HTTP.get(URI("http://localhost:#{port}/_nodes/?process&http")))
+ nodes = JSON.parse(Net::HTTP.get(URI("http://localhost:#{port}/_nodes/process,http")))
master = JSON.parse(Net::HTTP.get(URI("http://localhost:#{port}/_cluster/state")))['master_node']
puts "\n",
('-'*80).ansi(:faint),
'Cluster: '.ljust(20).ansi(:faint) + health['cluster_name'].to_s.ansi(:faint),