ICode9

精准搜索请尝试: 精确搜索
首页 > 编程语言> 文章详细

ElasticSearch Java API连接报错NoNodeAvailableException解决方案

2021-06-02 18:57:43  阅读:249  来源: 互联网

标签:Java 查看 settings client cluster API 报错 new 9300


 

如下代码:


public static void creatIndex(){
    // 1、获取客户端对象,设置连接的集群名称
   Settings settings= Settings.builder().put("cluster.name","elasticsearch").build();
    client=new PreBuiltTransportClient(settings);
    // 2、连接集群
    try {
        client.addTransportAddress(new InetSocketTransportAddress(InetAddress.getByName("hadoop-001"), 9300));
        System.out.println(client.toString());
    } catch (UnknownHostException e) {
        e.printStackTrace();
    }

    //1.创建索引(indices指数)
    client.admin().indices().prepareCreate("blog").get();
    //2.关闭连接
    client.close();
}


运行报错:


NoNodeAvailableException


 

 

查看日志如下:

java.lang.IllegalStateException: Received message from unsupported version: [5.2.2] minimal compatible version is: [5.6.0]

 

可知是版本太低,至少要5.6.0以上版本才行

 

修改后的pom.xml文件如下:



 
 
 



 
 
 



 
 
 


再次运行,成功!!!!!!

 

 

 

其他原因:

1.查看

cluster.name,是否是你服务器上在elasticsearch.yml上配置的

     2.查看
port:9300
val client = TransportClient.builder().settings(settings).build()
 .addTransportAddress(new InetSocketTransportAddress(InetAddress.getByName("******"), 9300))
      3.查看
      服务器的防火墙,是否关了。

     4.查看
        如果设置client.transport.sniff为true,则表示客户端去嗅探整个cluster的状态,把集群中其它机器的ip地址加到客户端中

标签:Java,查看,settings,client,cluster,API,报错,new,9300
来源: https://blog.51cto.com/u_15241496/2847742

本站声明: 1. iCode9 技术分享网(下文简称本站)提供的所有内容,仅供技术学习、探讨和分享;
2. 关于本站的所有留言、评论、转载及引用,纯属内容发起人的个人观点,与本站观点和立场无关;
3. 关于本站的所有言论和文字,纯属内容发起人的个人观点,与本站观点和立场无关;
4. 本站文章均是网友提供,不完全保证技术分享内容的完整性、准确性、时效性、风险性和版权归属;如您发现该文章侵犯了您的权益,可联系我们第一时间进行删除;
5. 本站为非盈利性的个人网站,所有内容不会用来进行牟利,也不会利用任何形式的广告来间接获益,纯粹是为了广大技术爱好者提供技术内容和技术思想的分享性交流网站。

专注分享技术,共同学习,共同进步。侵权联系[81616952@qq.com]

Copyright (C)ICode9.com, All Rights Reserved.

ICode9版权所有