我正在尝试连接到我的ES集群的最基本情况,但似乎我注册的主机没有被注册。这是我正在运行的代码:
//Create the client
Client client = new TransportClient(ImmutableSettings.builder()
.put("cluster.name", "MyCluster")
.put("client.transport.sniff","true").build())
.addTransportAddresses(
new InetSocketTransportAddress("host1", 9300),
new InetSocketTransportAddress("host2", 9300));
// Try to make a call
SearchRequest sr = new SearchRequest().indices("MyIndex");
ActionFuture<SearchResponse> search = client.search(sr);
SearchResponse actionGet = search.actionGet(); // <-- Exception
System.out.println(actionGet.toString());
client.close();
这是我得到的例外:
线程“主”org.elasticsearch.client.transport.NoNodeAvailableException
中的异常:配置的节点均不可用:[]
看起来没有连接的节点,我错过了什么?
注意:我正在使用带有 gradle 的弹性搜索客户端:
compile 'org.elasticsearch:elasticsearch:1.7.5'