Java Elasticsearch-Hadoop配置的节点均不可用

Question

因此，我正在运行一个Hadoop查询，它需要Amazon EC2上运行的ElasticSearch索引中的一个字段的信息。问题是，我总是得到“没有一个配置的节点可用”的错误。更令人沮丧的是，我几天前还在工作，但由于缺乏CPU操作，它在查询过程中退出了。但我的合作伙伴不知道这一点，所以他试图找出为什么它在查询中失去连接似乎导致了这个问题。他也不记得自己做了什么。

我知道以前有人问过这个问题，但我确信我的集群名称是正确的，我在ES上运行的查询不应该导致超时，以前运行时也没有。此外，不应该有防火墙问题，因为我直接在EC2实例上运行程序。它是一个使用YARN的伪分布式单节点集群。EC2实例有一个相关的弹性IP（这意味着它的公共IP将保持不变），并且运行Amazon的ubuntu映像。

下面是java代码（已删除标识信息）：

public static String getAccountNumber(int fieldValue){
    //tried it without the Settings, but still no dice.
    Settings settings = ImmutableSettings.settingsBuilder().put("cluster.name", "elasticsearch").build();
    TransportClient client = new TransportClient(settings)
       .addTransportAddress(new InetSocketTransportAddress("ec2-<ELASTIC_IP>.compute-1.amazonaws.com", 9300));
    FilterBuilder filter = boolFilter()
            .should(termFilter("objectName1.field", fieldValue))
            .should(termFilter("objectName2.field", fieldValue));
    SearchResponse response= client.prepareSearch("indexName")
            .setTypes("type")
            .setPostFilter(filter)
            .setSize(1000)
            .execute()
            .actionGet();
    //other logic

如果您需要我提供我的core-site.xml、hdfs-site.xml或其他东西，请告诉我。

Answer 1

解决了！在另一个逻辑部分，我有“client.close（）；”。发表意见解决了我的问题。