Java подключиться к Кассандре NoHostAvailableException

Мой код в Java:Java подключиться к Кассандре NoHostAvailableException

public static void main(String[] args) { 
    Cluster cluster; 
    Session session; 

    cluster = Cluster.builder() 
       .addContactPoint("127.0.0.1") 
       .withPort(9042) 
       .build(); 

    session = cluster.connect("Bundesliga"); 

    session.execute("INSERT INTO test(c1,c2,c3,c4,c5) VALUES(0,0,0,0,0)"); 
}

Сообщение об ошибке:

Исключение в потоке "основного" com.datastax.driver.core.exceptions.NoHostAvailableException: Все Хост (ы), попробованный для запроса, не прошел (попробовал: /127.0.0.1:9042 (null)) в com.datastax.driver.core.ControlConnection.reconnectInternal (ControlConnection.java:196) at com.datastax.driver. core.Cont rolConnection.connect (ControlConnection.java:80) at com.datastax.driver.core.Cluster $ Manager.init (Cluster.java:1145) at com.datastax.driver.core.Cluster.init (Cluster.java: 149) по адресу com.datastax.driver.core.Cluster.connect (Cluster.java:225) по адресу com.datastax.driver.core.Cluster.connect (Cluster.java:258) по адресу cassandra.cassandra_main.main (cassandra_main.java:19)

Я уже посмотрел в cassandra.yaml:

start_native_transport: истинный

native_transport_port: 9042

источник

2016-12-01 fsstudent

Вы уверены, что cassandra прислушивается к localhost? Поскольку узлы кластера cassandra должны разговаривать друг с другом, они обычно открывают свой порт на внешнем IP-адресе. –

в cassandra.yaml является listen_adress на localhost – fsstudent

вы можете включить вывод 'netstat -anp | grep 9042'? –

Я установил ее.

Проблема заключалась в том, что версия ядра cassandra-driver не была совместима с версией cassandra.

источник

2016-12-04 12:19:26 fsstudent

Java подключиться к Кассандре NoHostAvailableException

ответ

Смежные вопросы