java - 用于Elasticsearch的Java Transport Client抛出NoNodeAvailableException

Question

我是Elasticsearch的新手，试图连接到运行1.5.2版的远程集群。我已将相同版本的Maven依赖项添加到我的项目中。我正在使用以下Scala代码初始化Transport客户端:

val settings: Settings = ImmutableSettings.settingsBuilder().put("cluster.name", "clusterName").put("client.transport.sniff", true).build()
val client: Client = new TransportClient(settings).addTransportAddress(new InetSocketTransportAddress("XX.X.X.XX", 9300))

然后，当我尝试检查索引是否存在时，它将失败:

val exists = client.admin().indices().prepareExists("index").execute().actionGet().isExists()

“clusterName”与集群上elasticsearch.yml中的属性“cluster.name”匹配。我还尝试将client.transport.ping_timeout和client.transport.nodes_sampler_interval设置为30秒，但无济于事，并尝试了是否进行嗅探。

我已经在端口9200上使用curl来验证我可以在我的elasticsearch实例上进行索引和搜索。

相关堆栈跟踪:

org.elasticsearch.client.transport.NoNodeAvailableException: None of the configured nodes are available: []
    at org.elasticsearch.client.transport.TransportClientNodesService.ensureNodesAreAvailable(TransportClientNodesService.java:305)
    at org.elasticsearch.client.transport.TransportClientNodesService.execute(TransportClientNodesService.java:200)
    at org.elasticsearch.client.transport.support.InternalTransportIndicesAdminClient.execute(InternalTransportIndicesAdminClient.java:86)
    at org.elasticsearch.client.support.AbstractIndicesAdminClient.exists(AbstractIndicesAdminClient.java:170)
    at org.elasticsearch.action.admin.indices.exists.indices.IndicesExistsRequestBuilder.doExecute(IndicesExistsRequestBuilder.java:53)
    at org.elasticsearch.action.ActionRequestBuilder.execute(ActionRequestBuilder.java:91)
    at org.elasticsearch.action.ActionRequestBuilder.execute(ActionRequestBuilder.java:65)

在此先感谢您的协助。

Answer 1

我知道这是一个非常老的问题，但是对于这种情况，我知道一种解决方法是在您的设置中将嗅探添加到false

put("client.transport.sniff", false)