代码之家 › 专栏 › 技术社区 › user7982987

Datastax驱动程序连接异常DSE 5.0,CASSANDRA 3.0.7,spark

cassandra-3.0 spark-cassandra-connector datastax-java-driver datastax-enterprise java

user7982987 · 技术社区 · 7 年前

每当我运行spark作业时看到以下异常时,我都试图理解警告。我在3节点集群的2个节点中看到了这一点。但正如我所说,这只是警告,工作无论如何都会成功。

com.datastax.driver.core.exceptions.ConnectionException: [x.x.x.x/x.x.x.x:9042] Pool was closed during initialization

信息[SharedPool-Worker-1]2017-07-17 22:25:48716消息。java:605 io.netty.channel.unix。错误$NativeIoException:readAddress()失败: 连接超时 ~[netty-all-4.0.34。最终。jar:4.0.34。最终] at io.netty.channel.unix.FileDescriptor.readAddress(FileDescriptor.java:134) ~[netty-all-4.0.34。最终。jar:4.0.34。最终] ~[netty-all-4.0.34。最终。jar:4.0.34。最终] 在io.netty.channel.epoll.EpollEventLoop.processReady(EpollEventLoop.java:348) ~[netty-all-4.0.34。最终。jar:4.0.34。最终] ~[netty-all-4.0.34。最终。jar:4.0.34。最终] ~[netty-all-4.0.34。最终。jar:4.0.34。最终] 在io.netty.util.concurrent.DefaultThreadFactory$DefaultRunnableDecorator.run(DefaultThreadFactory.java:137) ~[netty-all-4.0.34。最终。jar:4.0.34。最终] 在java.lang.Thread.run(Thread.java:745)[na:1.8.0_121]

1 回复 | 直到 7 年前

Chris Nauroth 7 年前

ping , telnet 和 nc .一些潜在原因:

Cassandra客户端的连接配置包含无效的地址(不是Cassandra集群中的节点)。
网络配置错误或防火墙规则阻止了从客户端到Cassandra服务器的连接。
目标Cassandra服务器过载,无法响应新的连接请求。

您提到该问题是间歇性的(“在我的3节点集群的2个节点中可以看到”),并且不会导致作业失败。这可能表明以上列出的任何问题只发生在集群中的一部分节点上。(如果与所有节点的连接中断,则作业可能会失败。)

推荐文章

Vishal Chaurasia · 配置cassandra 3.11.2以接受ec2上的远程连接

7 年前

Vishal Sharma · 从Ignite看Cassandra的Blob

7 年前

iMajna · 无法修复Cassandra中特定节点上的特定表

7 年前

Harry · Cassandra中的分布式日志

7 年前

Alisson Gomes · linux中的Cassandra自定义系统路径

7 年前

Harry · 墓碑vs nodetool与修复

7 年前

jamesrogers93 · 用于检索时间序列财务数据摘要的高效Cassandra DB设计

7 年前

Vishal Sharma · 在Cassandra中使用MetricsServlet获取度量

7 年前

Garima · 命令在cassandra中的表中搜索值的一部分

7 年前

Manu Chadha · 如何在应用程序中具体化Cassandra的配置属性。形态?

7 年前