多线程时Datastax Cassandra NonoodeAvailableException

Question

我正在尝试用Java构建一个多线程Cassandra导入器。我正在使用这个包：
组：'com。税收。cassandra，名称：“cassandra驱动核心”，版本：“4.0.0”

单线程（使用主线程）工作正常，但即使有1个子线程，我也会立即收到com.datastax.oss.driver.api.core.NoNode可用性异常：没有节点可用于执行查询

我正在Docker的cassandra实例上测试我的应用程序（希望这不是问题）。这就是我的建筑商。

            session = CqlSession.builder()
                    .addContactPoint(new InetSocketAddress("localhost", 9042))
                    .withKeyspace(CqlIdentifier.fromCql("links"))
                    .withLocalDatacenter("datacenter1")
                    .build();

这就是我执行查询的方式

        JSONObject json = new JSONObject(linksRow);
        JsonInsert query = insertInto("links").json(json.toString());
        session.execute(query.toString());

你能告诉我我做错了什么吗？根据文档，CqlSession应该是线程安全的。(https://docs.datastax.com/en/developer/java-driver/4.0/manual/core/)

编辑：添加插入查询

Answer 1

JsonInsert query = insertInto("links").json(json.toString());

这些查询是否在每个线程上持续运行？

可能是本地单个Cassandra节点没有足够的资源来处理多个请求。这将导致Cassandra返回节点对客户端“不可用”。

卡桑德拉的Java堆有多大？它可能需要更大。也可能是本地系统运行卡桑德拉，一个多线程应用程序，以及其他可能正在运行的东西太多了。

基本上，检查conf/jvm服务器的“堆设置”。选项。如果堆被“自动计算”，那么对于应用程序试图用它做的事情来说，堆可能太小了。