I am trying to use Java 2.3 client API to connect to ElasticSearch has two nodes configration(1 master, 1 data node). However its stuck at the TransportClient.builder().settings(settings).build().
My code which create a client:
this.elasticsearchEndpoint = elasticSearchEndpoint;
this.elasticsearchPort = elasticSearchPort;
Settings settings = Settings.settingsBuilder()
.put("cluster.name", elasticSearchClusterName)
.put(ELASTICSEARCH_CLIENT_TRANSPORT_SNIFF_KEY, true).build();
TransportClient.Builder builder = TransportClient.builder().settings(settings);
log.debug("ElasticsearchEmitter using raweventkcl endpoint");
this.elasticsearchClient = builder.build();
log.debug("ElasticsearchEmitter using raweventkcl endpoint");
There is log before builder. build();
but noting else after that.
log:
2016-06-13 01:27:06,045 UTC [INFO] (main) org.elasticsearch.plugins: [Agamotto] modules [], plugins [], sites []
2016-06-13 01:27:06,046 UTC [DEBUG] (main) org.elasticsearch.threadpool: [Agamotto] creating thread_pool [force_merge], type [fixed], size [1], queue_size [null]
2016-06-13 01:27:06,046 UTC [DEBUG] (main) org.elasticsearch.threadpool: [Agamotto] creating thread_pool [percolate], type [fixed], size [8], queue_size [1k]
2016-06-13 01:27:06,046 UTC [DEBUG] (main) org.elasticsearch.threadpool: [Agamotto] creating thread_pool [fetch_shard_started], type [scaling], min [1], size [16], keep_alive [5m]
2016-06-13 01:27:06,046 UTC [DEBUG] (main) org.elasticsearch.threadpool: [Agamotto] creating thread_pool [listener], type [fixed], size [4], queue_size [null]
2016-06-13 01:27:06,046 UTC [DEBUG] (main) org.elasticsearch.threadpool: [Agamotto] creating thread_pool [index], type [fixed], size [8], queue_size [200]
2016-06-13 01:27:06,046 UTC [DEBUG] (main) org.elasticsearch.threadpool: [Agamotto] creating thread_pool [refresh], type [scaling], min [1], size [4], keep_alive [5m]
2016-06-13 01:27:06,046 UTC [DEBUG] (main) org.elasticsearch.threadpool: [Agamotto] creating thread_pool [suggest], type [fixed], size [8], queue_size [1k]
2016-06-13 01:27:06,046 UTC [DEBUG] (main) org.elasticsearch.threadpool: [Agamotto] creating thread_pool [generic], type [cached], keep_alive [30s]
2016-06-13 01:27:06,046 UTC [DEBUG] (main) org.elasticsearch.threadpool: [Agamotto] creating thread_pool [warmer], type [scaling], min [1], size [4], keep_alive [5m]
2016-06-13 01:27:06,046 UTC [DEBUG] (main) org.elasticsearch.threadpool: [Agamotto] creating thread_pool [search], type [fixed], size [13], queue_size [1k]
2016-06-13 01:27:06,046 UTC [DEBUG] (main) org.elasticsearch.threadpool: [Agamotto] creating thread_pool [flush], type [scaling], min [1], size [4], keep_alive [5m]
2016-06-13 01:27:06,046 UTC [DEBUG] (main) org.elasticsearch.threadpool: [Agamotto] creating thread_pool [fetch_shard_store], type [scaling], min [1], size [16], keep_alive [5m]
2016-06-13 01:27:06,046 UTC [DEBUG] (main) org.elasticsearch.threadpool: [Agamotto] creating thread_pool [management], type [scaling], min [1], size [5], keep_alive [5m]
2016-06-13 01:27:06,046 UTC [DEBUG] (main) org.elasticsearch.threadpool: [Agamotto] creating thread_pool [get], type [fixed], size [8], queue_size [1k]
2016-06-13 01:27:06,046 UTC [DEBUG] (main) org.elasticsearch.threadpool: [Agamotto] creating thread_pool [bulk], type [fixed], size [8], queue_size [50]
2016-06-13 01:27:06,046 UTC [DEBUG] (main) org.elasticsearch.threadpool: [Agamotto] creating thread_pool [snapshot], type [scaling], min [1], size [4], keep_alive [5m]
Any idea about this.