scala - "[NoHostAvailableException: All host(s) tried for query failed"连接cassandra集群出现异常

Question

var cluster: Cluster = null
var session: Session = null
cluster = Cluster.builder().addContactPoints("192.168.1.3","192.168.1.2").build()
val metadata = cluster.getMetadata()
printf("Connected to cluster: %s\n",
metadata.getClusterName())
metadata.getAllHosts() map {
case host =>
  printf("Datatacenter: %s; Host: %s; Rack: %s\n",
    host.getDatacenter(), host.getAddress(), host.getRack())

}

我无法使用此代码连接到 cassandra 集群。它给我的错误是——
[NoHostAvailableException: All host(s) tried for query failed (tried: /192.168.1.3 ([/192.168.1.3] Cannot connect), /192.168.1.2 ([/192.168.1.2] Cannot connect))]
我在上面的代码中有什么错误。

Answer 1

你的代码乍一看还不错。该错误表明 Cassandra 实际上并未在 IP“192.168.1.3”、“192.168.1.2”上的端口 9042(默认)上运行

如果 Cassandra 在这些 IP 上运行，但它是您需要使用的另一个端口

int port = 19042; // Put the correct port here
cluster = Cluster.builder().addContactPoints("192.168.1.3","192.168.1.2").withPort(port).build()