cassandra-user mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From Michael Shuler <mich...@pbandjelly.org>
Subject Re: com.datastax.driver.core.exceptions.NoHostAvailableException
Date Thu, 26 Apr 2018 13:45:43 GMT
host421 != bluej421
My guess is 192.168.3.232 != {host421,bluej421} somewhere.

If DNS hostnames are being used, the DNS infrastructure needs to be spot
on, forward and reverse. If the DNS infrastructure is /etc/hosts, those
hosts entries need to be spot on for the entire cluster, forward and
reverse.

`ping` your hosts from nodes themselves and from remote nodes. Check the
listening ports on all nodes with `netstat`. `telnet $host $port`
locally and remotely. Were the results expected?

Basically, if using DNS, it has to be right everywhere and a lot of
people get DNS wrong.

-- 
Kind regards,
Michael

On 04/26/2018 08:17 AM, Lou DeGenaro wrote:
> version: cassandra-3.0.9
> 
>     conf/cassnadra.yaml changes:
> 
>               - seeds: "host421"
>     listen_address: host421
>     rpc_address: host421
> 
> 
> Java client:
> 
>     package database.tools;
> 
>     import java.net.InetSocketAddress;
>     import java.util.Map;
>     import java.util.Map.Entry;
> 
>     import com.datastax.driver.core.AuthProvider;
>     import com.datastax.driver.core.Cluster;
>     import com.datastax.driver.core.PlainTextAuthProvider;
>     import com.datastax.driver.core.Session;
>     import com.datastax.driver.core.exceptions.NoHostAvailableException;
> 
>     public class Creator {
>        
>         private static Cluster cluster;
>         private static Session session = null;
>        
>         private static String dburl = "host421";
>        
>         public static void main(String[] args) {
>             try {
>                 AuthProvider auth = new
>     PlainTextAuthProvider("cassandra", "cassandra");
>                 cluster = Cluster.builder()
>                     .withAuthProvider(auth)
>                     .addContactPoint(dburl)
>                     .build();
>                    
>                 session = cluster.connect();
>             }
>             catch(NoHostAvailableException e) {
>                 e.printStackTrace();
>                 Map<InetSocketAddress, Throwable> map = e.getErrors();
>                 for(Entry<InetSocketAddress, Throwable> entry :
>     map.entrySet()) {
>                     Throwable t = entry.getValue();
>                     t.printStackTrace();
>                 }
>             }
>             catch(Exception e) {
>                 e.printStackTrace();
>             }
>         }
> 
>     }
> 
> 
> Result:
> 
>      INFO | Found Netty's native epoll transport in the classpath, using it
>     com.datastax.driver.core.exceptions.NoHostAvailableException: All
>     host(s) tried for query failed (tried: bluej421/192.168.3.232:9042
>     <http://192.168.3.232:9042>
>     (com.datastax.driver.core.exceptions.InvalidQueryException:
>     unconfigured table schema_keyspaces))
>         at
>     com.datastax.driver.core.ControlConnection.reconnectInternal(ControlConnection.java:227)
>         at
>     com.datastax.driver.core.ControlConnection.connect(ControlConnection.java:86)
>         at com.datastax.driver.core.Cluster$Manager.init(Cluster.java:1409)
>         at com.datastax.driver.core.Cluster.init(Cluster.java:160)
>         at com.datastax.driver.core.Cluster.connectAsync(Cluster.java:338)
>         at com.datastax.driver.core.Cluster.connectAsync(Cluster.java:311)
>         at com.datastax.driver.core.Cluster.connect(Cluster.java:250)
>         at org.apache.uima.ducc.database.tools.Creator.main(Creator.java:28)
>     com.datastax.driver.core.exceptions.InvalidQueryException:
>     unconfigured table schema_keyspaces
>         at
>     com.datastax.driver.core.Responses$Error.asException(Responses.java:102)
>         at
>     com.datastax.driver.core.DefaultResultSetFuture.onSet(DefaultResultSetFuture.java:149)
>         at
>     com.datastax.driver.core.DefaultResultSetFuture.onSet(DefaultResultSetFuture.java:167)
>         at
>     com.datastax.driver.core.Connection$Dispatcher.channelRead0(Connection.java:1013)
>         at
>     com.datastax.driver.core.Connection$Dispatcher.channelRead0(Connection.java:936)
>         at
>     io.netty.channel.SimpleChannelInboundHandler.channelRead(SimpleChannelInboundHandler.java:105)
>         at
>     io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:339)
>         at
>     io.netty.channel.AbstractChannelHandlerContext.fireChannelRead(AbstractChannelHandlerContext.java:324)
>         at
>     io.netty.handler.timeout.IdleStateHandler.channelRead(IdleStateHandler.java:254)
>         at
>     io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:339)
>         at
>     io.netty.channel.AbstractChannelHandlerContext.fireChannelRead(AbstractChannelHandlerContext.java:324)
>         at
>     io.netty.handler.codec.MessageToMessageDecoder.channelRead(MessageToMessageDecoder.java:103)
>         at
>     io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:339)
>         at
>     io.netty.channel.AbstractChannelHandlerContext.fireChannelRead(AbstractChannelHandlerContext.java:324)
>         at
>     io.netty.handler.codec.ByteToMessageDecoder.channelRead(ByteToMessageDecoder.java:242)
>         at
>     io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:339)
>         at
>     io.netty.channel.AbstractChannelHandlerContext.fireChannelRead(AbstractChannelHandlerContext.java:324)
>         at
>     io.netty.channel.DefaultChannelPipeline.fireChannelRead(DefaultChannelPipeline.java:847)
>         at
>     io.netty.channel.epoll.EpollSocketChannel$EpollSocketUnsafe.epollInReady(EpollSocketChannel.java:722)
>         at
>     io.netty.channel.epoll.EpollEventLoop.processReady(EpollEventLoop.java:326)
>         at
>     io.netty.channel.epoll.EpollEventLoop.run(EpollEventLoop.java:264)
>         at
>     io.netty.util.concurrent.SingleThreadEventExecutor$2.run(SingleThreadEventExecutor.java:111)
>         at java.lang.Thread.run(Thread.java:811)
> 
> 
> Surely user error, but what is being done wrongly please?
> 
> Thanks.
> 
> Lou.


---------------------------------------------------------------------
To unsubscribe, e-mail: user-unsubscribe@cassandra.apache.org
For additional commands, e-mail: user-help@cassandra.apache.org


Mime
View raw message