Hi,
I'm getting these sudden no node available exceptions and they continue to
persist over multiple calls untill the elastic search server or apache
tomcat is restarted. Below is how i'm getting the client and running the
query. I've just kept the relevant things in the code below.
Pls let me know if anyone has faced this issue. Apparently there are a lot
of posts related to this issue but none of them gave me a clear idea.
private static Client getClient(UserRequest userRequest,Map<String, String>credentialMap
)
{
if(null==client) // client is a static instance variable
{
Settings settings = ImmutableSettings.settingsBuilder()
.put("cluster.name", credentialMap.get(ES_CLUSTER))
.put("client.transport.sniff", true)
.put("node.client", true)
.put("client.transport.ping_timeout","10s").build();
client = new TransportClient(settings).addTransportAddress(new
InetSocketTransportAddress(credentialMap.get(ES_HOST), Integer.parseInt(
credentialMap.get(ES_JAVA_PORT))));
}
return client;
}
protected SearchResponse runJavaApiQuery(SearchRequestBuilder srb)
{
return srb.execute().actionGet();
}
protected SearchRequestBuilder getSearchRequestBuilder(QueryBuilderqueryBuilder
, UserRequest userRequest,Map<String, String> credentialMap)
{
return getClient(userRequest,credentialMap).prepareSearch(credentialMap.get
(ES_INDEX)).setSearchType(SearchType.QUERY_THEN_FETCH).setQuery(queryBuilder
);
}
Thanks,
john
--
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+unsubscribe@googlegroups.com.
For more options, visit https://groups.google.com/groups/opt_out.