Elasticsearch - NoNodeAvailableException

Question

尝试使用 ES 2 的 Java API 连接到 Elasticsearch 2 时出现以下错误。代码如下：

Settings settings = Settings.settingsBuilder().put("cluster.name", Receptor.clusterName).build();
TransportClient transportClient = TransportClient.builder().settings(settings).build();
Client c = null;
try {
     c = transportClient.addTransportAddress(new InetSocketTransportAddress(InetAddress.getByName(Receptor.es_ip), 9300));
} catch (UnknownHostException e) {
     System.err.println(Util.getTimestampStr() + "UnknownHostException error.");
     e.printStackTrace();
}

CreateIndexRequestBuilder createIndexRequestBuilder = c.admin().indices().prepareCreate(indexName);
createIndexRequestBuilder.addMapping(documentName, json);
createIndexRequestBuilder.execute().actionGet();

我能够在 transportClient.connectedNodes() 上获取我的 ES 节点，但是当我尝试添加新映射时，我得到 NoNodeAvailableException 异常。此代码适用于以前版本的 Elasticsearch。知道出了什么问题吗？

NoNodeAvailableException[None of the configured nodes are available:
[]]     at
org.elasticsearch.client.transport.TransportClientNodesService.ensureNodesAreAvailable(TransportClientNodesService.java:280)
    at
org.elasticsearch.client.transport.TransportClientNodesService.execute(TransportClientNodesService.java:197)
    at
org.elasticsearch.client.transport.support.TransportProxyClient.execute(TransportProxyClient.java:55)
    at
org.elasticsearch.client.transport.TransportClient.doExecute(TransportClient.java:272)
    at
org.elasticsearch.client.support.AbstractClient.execute(AbstractClient.java:347)
    at
org.elasticsearch.client.support.AbstractClient$IndicesAdmin.execute(AbstractClient.java:1177)
    at
org.elasticsearch.action.ActionRequestBuilder.execute(ActionRequestBuilder.java:85)
    at
org.elasticsearch.action.ActionRequestBuilder.execute(ActionRequestBuilder.java:59)

Answer 1

@AndreiStefan 感谢the post he linked，为我的问题提供了解决方案。解决方案很简单：

network.bind_host: 0

谢谢你们。

Answer 2

问题可能出在您使用的设置中。

而不是通过这三个步骤创建客户端：

TransportClient transportClient = TransportClient.builder().settings(settings).build();
Client c = null;
try {
 c = transportClient.addTransportAddress(new InetSocketTransportAddress(InetAddress.getByName(Receptor.es_ip), 9300));
} catch (UnknownHostException e) {
 System.err.println(Util.getTimestampStr() + "UnknownHostException error.");
 e.printStackTrace();
}

尝试像这样创建它：

Client client = new TransportClient()
            .addTransportAddress(new InetSocketTransportAddress(
                    InetAddress.getByName(Receptor.es_ip),
                    9300));

如果您想要更多数据，请查看类似问题的旧答案：Elastic search problems

Answer 3

如果您在 elasticsearch.yml 中使用 network.host: _site_ 和 sniffed TransportClient 连接，则此问题可能是由于网络问题，即托管 es 节点的机器中有多个站点本地地址可用。

如果您禁用嗅探配置，并且 NoNodeAvailableException 消失，那么您应该仔细检查网络配置。

获取节点统计信息

GET /_nodes

并检查结果以找到transport配置，即

"transport": {
    "bound_address": [
      "192.168.1.84:9300",
      "172.29.0.1:9300"
    ],
    "publish_address": "172.29.0.1:9300",
    "profiles": {}
  },

如果有多个站点本地地址，则嗅探到 TransportClient 将连接到的 network.publish_host 可能是一个意外地址，因为

如果未指定，则默认为 network.host 中的“最佳”地址，按 IPv4/IPv6 堆栈首选项排序，然后按可达性排序。

要解决它，只需指定network.publish_host

network.publish_host: $DESIRED_IP_ADDRESS

在 elasticsearch.yml 中。