java - 连接到 Cassandra 集群时 Java 应用程序(Wasabi)失败
问题描述
我正在开发 Wasabi - A/B 测试工具。我使用 Cassanra DB(3.11) 和 Datastax 驱动程序(3.5.0)。应用程序在单个 Cassandra 节点上启动良好,但在多个节点上失败。例外是:
77467 [main] ERROR c.i.w.c.d.DefaultCassandraDriver - Exception occurred while connecting to the cluster...
com.datastax.driver.core.exceptions.NoHostAvailableException: All host(s) tried for query failed (no host was tried)
答案:
DefaultCassandraDriver.class 有配置:
builder.withLoadBalancingPolicy(新 TokenAwarePolicy(新 DCAwareRoundRobinPolicy.Builder()...
DCAwareRoundRobinPolicy 不起作用,它与 RoundRobinPolicy 一起使用(它可以在那里配置)。我不知道有什么影响,也许只是缺少配置。
我想向 Wasabi 和任何其他 Datastax 用户指出这一点
解决方案
回答:
DefaultCassandraDriver.class 有配置:
builder.withLoadBalancingPolicy(
new TokenAwarePolicy(
new DCAwareRoundRobinPolicy.Builder()
...
DCAwareRoundRobinPolicy 不起作用,它与 RoundRobinPolicy 一起使用(它可以在那里配置)。我不知道有什么影响,也许只是缺少配置。
我想向 Wasabi 和任何其他 Datastax 用户指出这一点
推荐阅读
- python - 使用 Python 脚本从节点导出器指标获取 cpu、内存、磁盘数据
- java - Maven 阴影插件无法将 Spring Boot 版本从 2.3.3 更新到 2.4.0
- google-sheets - Google表格脚本合并行和列
- regex - 在打字稿中使用正则表达式获取两个字符之间的字符串
- html - 不能 GET /Login 或更高版本不能 POST /Login
- c++ - 有没有办法将参数化函数作为回调函数中的参数传递
- node.js - 加载 libatk-bridge-2.0.so.0 时出错
- javascript - 带参数的角路由器
- firebase - 我们如何将下拉按钮表单字段中的值保存到flutter中的firebase?
- scala - 如何在有条件的 Spark 数据框中获取行数?