当我遇到这个错误时,我正在尝试在 cassandra 中插入值:
15/08/14 10:21:54 INFO Cluster: New Cassandra host /a.b.c.d:9042 added
15/08/14 10:21:54 INFO Cluster: New Cassandra host /127.0.0.1:9042 added
INFO CassandraConnector: Connected to Cassandra cluster: Test Cluster
15/08/14 10:21:54 ERROR Session: Error creating pool to /127.0.0.1:9042
com.datastax.driver.core.TransportException: [/127.0.0.1:9042] Cannot connect
at com.datastax.driver.core.Connection.<init>(Connection.java:109)
at com.datastax.driver.core.PooledConnection.<init>(PooledConnection.java:32)
at com.datastax.driver.core.Connection$Factory.open(Connection.java:586)
at com.datastax.driver.core.SingleConnectionPool.<init>(SingleConnectionPool.java:76)
at com.datastax.driver.core.HostConnectionPool.newInstance(HostConnectionPool.java:35)
at com.datastax.driver.core.SessionManager.replacePool(SessionManager.java:271)
at com.datastax.driver.core.SessionManager.access$400(SessionManager.java:40)
at com.datastax.driver.core.SessionManager$3.call(SessionManager.java:308)
at com.datastax.driver.core.SessionManager$3.call(SessionManager.java:300)
at java.util.concurrent.FutureTask$Sync.innerRun(FutureTask.java:334)
at java.util.concurrent.FutureTask.run(FutureTask.java:166)
at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1110)
at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:603)
at java.lang.Thread.run(Thread.java:722)
Caused by: java.net.ConnectException: Connection refused: /127.0.0.1:9042
我的复制因子是 1。Cass 集群中有 5 个节点(它们都已启动)。 rpc_address: 0.0.0.0, broadcast_rpc_address: 127.0.0.1
我认为对于 5 个节点中的每一个,我应该从上方看到 5 个“INFO Cluster: New Cassandra host..”行。 但我看到的不是 127.0.0.1,我不确定为什么。
我还注意到在 cassandra.yaml 文件中,所有 5 个节点都列在种子下。 (我知道不建议这样做,但我没有设置这个集群)
seed_provider:
class_name: org.apache.cassandra.locator.SimpleSeedProvider
parameters:
seeds: "ip1, ip2, ip3, ip4, ip5"
其中 ipx 是节点 x 的 ipaddr。
在 cassandra-topology.properties 下,它只是说明了以下内容,并没有提及 5 个节点中的任何一个。
# default for unknown nodes
default=DC1:r1
有人能解释一下为什么我会看到 ERROR Session: Error creating pool to/127.0.0.1:9042 错误。
Cassandra 有点新..提前致谢!
最佳答案
我认为问题在于您的 rpc_broadcast_address 设置为 127.0.0.1。您这样做有什么特别的原因吗?
java 驱动程序使用 system.peers 表来查找用于连接到主机的 IP 地址。如果设置了 rpc_broadcast_address,这将出现在 system.peers 中,驱动程序将尝试使用它。如果未设置 rpc_broadcast_address,将使用 rpc_address。无论哪种情况,您都希望将其中一个地址设置为您的客户可以访问的地址。如果设置了 rpc_address,则需要删除 broadcast_rpc_address。
关于configuration - 错误 session : Error creating pool to/127. 0.0.1:9042,我们在Stack Overflow上找到一个类似的问题: https://stackoverflow.com/questions/32012777/