提供ReceiveTimeoutTransportException的

Question

嗨，我正在尝试连接我的ElasticSearch客户端到我的本地主机，并尝试从那里获得索引。

import org.elasticsearch.action.get.GetResponse;
import org.elasticsearch.client.Client;
import org.elasticsearch.node.Node;
import org.elasticsearch.client.transport.*;
import org.elasticsearch.common.transport.*;
import java.io.IOException;
import static org.elasticsearch.node.NodeBuilder.nodeBuilder;
public class ESClient
{
    public static void search()throws IOException
    {
        Node node;
        node = nodeBuilder().clusterName("elasticsearch").node();
        Client client;
        client= new TransportClient()
                .addTransportAddress(new InetSocketTransportAddress("localhost", 9200));
        GetResponse response;
        response= client.prepareGet("twitter", "tweet", "1").execute() .actionGet();
        System.out.println(response.toString());

    }
    public static void main(String args[])throws IOException
    {
        search();

    }

}

curl-xput'http://localhost:9200/twitter/'curl-xput'http://localhost:9200/twitter/_mapping/tweet'-d'{
“tweet”：{“properties”：{
“message”：{“type”：“string”,“store”：true}}
}}“

当我执行它时,会抛出以下错误,

NFO：[Blackheath]无法获取[#Transport#-1][BLRMCB-C02L56J4DR53.Local][iNet[LocalHost/127.0.0.1:9200]]的节点信息，正在断开连接...org.elasticsearch.transport.receiveTimeoutTransportException：[][iNet[localhost/127.0.0.1:9200]][cluster:监视器/节点/信息]request_id[0]在org.elasticsearch.transport.transportservice$timeouthandler.run（transportservice.java:366)（java.util.concurrent.ThreadPoolExecutor.Runworker（ThreadPoolExecutor.1142)（java.util.concurrent.ThreadPoolExecutor$worker.run（

线程“main”org.elasticsearch.client.transport.nonodeAvailable异常：没有任何已配置的节点可用：[]at org.elasticsearch.client.transport.transportclientnodesservice.cailable（transportclientnodesservice.java:278)at org.elasticsearch.client.transport.transportclientnodesservice.javae.execute（transportclientnodesservice.197)at org.elasticsearch.client.transport.transportclient.execute（Reflect.NativeMethodAccessorImpl.Invoke0（本机方法）（位于Sun.Reflect.NativeMethodAccessorImpl.java:62)（位于Sun.Reflect.DelegatingMethodAccessorImpl.java:43)（位于java.lang.Reflect.Method.Invoke(Method.java:497)（位于com.intellij.rt.Execution.Application.AppMain.Main（AppMain.java:140)

有什么问题，有人能告诉我吗？

Answer 1

当我从使用ElasticSearchAdapter进行查询切换到使用SparkStreamingAdapter进行相同的查询时，我得到了这个错误。我不得不把端口改成9300，然后这个错误就没有出现了。

这个问题/答案帮助我弄清楚了这一点：为什么我不能通过Java API连接到ElasticSearch？