Yes, it's client.threadPool().shutdown(). Jörg
On Tue, Aug 12, 2014 at 4:17 PM, Kfeenz <kfeeney5...@gmail.com> wrote: > @Jorg, > > Thanks for the advice, I will make sure that I do so during actual > implementation, but this is purely for testing the connection.. Also, I see > a client.close() and a client.threadPool().shutdown(), but I do not see a > client.threadPool().close(). I am using ES v1.3.1. > > @ Vivek, > > I am not sure how you were able to use 'localhost' vise "localhost". Java > complains about an invalid character constant because 'localhost' is not a > character but a String... > > My current code is as follows... with still no luck... > > Settings settings = ImmutableSettings.settingsBuilder().put("cluster.name", > "mycluster").build(); > > Client client = new TransportClient(settings).addTransportAddress(new > InetSocketTransportAddress("localhost", 9300)); > > ClusterStatsRequestBuilder builder = > client.admin().cluster().prepareClusterStats(); > > ClusterStatsResponse response = builder.execute().actionGet(); // fails on > execute... NoNodeAvailableException > > assertEquals("mycluster", response.getClusterName()); // never gets to > this point > > NoNodeAvailableException: None of the configured nodes are available [] > > If I add a setting to the settings object > > .put("client.transport.sniff", true); > > I get a different error - [org.elasticsearch.client.transport] [Argus] > failed to get local cluster state info for [#transport#-1]... > > I can query the cluster using > *http://localhost:9200/_cluster/health?pretty=true > <http://localhost:9200/_cluster/health?pretty=true>* which returns > > { > "cluster_name" : "mycluster", > "status" : "green", > "timed_out" : false, > "number_of_nodes" : 1, > "number_of_data_nodes" : 1, > "active_primary_shards" : 0, > "active_shards" : 0, > "relocating_shards" : 0, > "initializing_shards" : 0, > "unassigned_shards" : 0 > } > > I am on Windows 7 64-bit. > I am using Java 1.7_u55. > I am using ES version 1.3.1. > I have included in my pom.xml: > - elasticsearch-1.3.1.jar > - lucene-core-4.9.0.jar > > Any other suggestions are greatly appreciated. > > > > On Tuesday, August 12, 2014 5:45:16 AM UTC-4, Vivek Sachdeva wrote: >> >> Replace >> >> .setTransportAddress(new InetSocketTransportAddress("localhost", 9300)); >> >> with >> >> .addTransportAddress(new InetSocketTransportAddress('localhost', 9300)). >> >> And I guess if you dont give cluster name, it automatically joins the >> default cluster. >> >> I tried the code that you provided and changed above mentioned code. It >> works on my end. Can you try it? >> >> On Monday, August 11, 2014 11:34:43 PM UTC+5:30, Kfeenz wrote: >>> >>> So I am very new to elasticsearch... so I apologize in advance.. >>> >>> I started a local instance of elasticsearch and I am trying to connect >>> to it through the Java API. >>> >>> I was under the impression that the transport client was for remote >>> clients? >>> >>> I tried: >>> >>> @Test >>> public void testIndexResponse() { >>> >>> Client client = new TransportClient().setTransportAddress(new >>> InetSocketTransportAddress("localhost", 9300)); >>> >>> String json = "{" + >>> "\"user\":\"kimchy\"," + >>> "\"postDate\":\"2013-01-30\"," + >>> "\"message\":\"trying out Elasticsearch\"" + >>> "}"; >>> >>> IndexResponse response = client.prepareIndex("twitter", "tweet") >>> .setSource(json) >>> .execute() >>> .actionGet(); >>> >>> >>> client.close(); >>> >>> System.out.println(response.getIndex()); >>> } >>> >>> I receive org.elasticsearch.client.transport.NoNodeAvailableException: >>> None of the configured nodes are available: []. >>> >>> >>> >>> On Monday, August 11, 2014 1:19:06 PM UTC-4, Vivek Sachdeva wrote: >>>> >>>> Have you tried using transport client for connecting... >>>> >>>> On Monday, August 11, 2014 10:26:29 PM UTC+5:30, Kfeenz wrote: >>>>> >>>>> All, >>>>> >>>>> I know this post is old, but I continue to have an issue with this... >>>>> >>>>> I get an NoSuchMethodError: org.apache.log4j.Logger.isTraceEnabled()Z >>>>> exception when I run >>>>> >>>>> Node node = NodeBuilder.nodeBuilder().local(true).node(); // >>>>> exception thrown here... >>>>> Client client = node.client(); >>>>> >>>>> I have tried including several different slf4j and log4j libraries... >>>>> >>>>> Right now I have defined in my pom.xml: >>>>> >>>>> slf4j-api-1.7.7.jar >>>>> slf4j-ext-1.7.7.jar >>>>> log4j-core-2.0.jar >>>>> log4j-api-2.0.jar >>>>> >>>>> Any suggestions? >>>>> log4j-slf4j-impl-2.0.jar >>>>> >>>>> On Wednesday, November 30, 2011 6:55:57 PM UTC-5, Sam wrote: >>>>>> >>>>>> All >>>>>> >>>>>> I have a webapp (JAVA) with a list of items on the page. All these >>>>>> items are generated on html with session variables. I want to use >>>>>> ElasticSearch on the back end to do a search for items with different >>>>>> search criteria. Is there a sample I can use it as a resource? >>>>>> >>>>>> Thanks >>>>>> >>>>>> -- > You received this message because you are subscribed to the Google Groups > "elasticsearch" group. > To unsubscribe from this group and stop receiving emails from it, send an > email to elasticsearch+unsubscr...@googlegroups.com. > To view this discussion on the web visit > https://groups.google.com/d/msgid/elasticsearch/090eaed6-ce13-4460-8db1-b6913e6f1582%40googlegroups.com > <https://groups.google.com/d/msgid/elasticsearch/090eaed6-ce13-4460-8db1-b6913e6f1582%40googlegroups.com?utm_medium=email&utm_source=footer> > . > > For more options, visit https://groups.google.com/d/optout. > -- You received this message because you are subscribed to the Google Groups "elasticsearch" group. To unsubscribe from this group and stop receiving emails from it, send an email to elasticsearch+unsubscr...@googlegroups.com. To view this discussion on the web visit https://groups.google.com/d/msgid/elasticsearch/CAKdsXoE1tA2Mss3C9NgYEc5Cv%2Bft9-CHz3aA_zRpnwWy1RUYvQ%40mail.gmail.com. For more options, visit https://groups.google.com/d/optout.