PT2S后Cassandra写入查询超时

Question

我有cassandra单片应用程序，我想写在高速率从队列中读取一些有效载荷。Cassandra集群有3个节点。当我开始并行处理大量消息(通过生成线程)时，我得到以下异常

java.util.concurrent.ExecutionException: com.datastax.oss.driver.api.core.DriverTimeoutException: Query timed out after PT2S

我将CQLsession创建为bean

return CqlSession.builder().addContactPoints(contactPoints)
            /*.addContactPoint(new InetSocketAddress("localhost", 9042))*/
            .withConfigLoader(new DefaultDriverConfigLoader()).withLocalDatacenter("datacenter1")
            .addTypeCodecs(new CustomDateCodec())
            .withKeyspace("dev").build();

我将此CqlSession注入到映射器和其他类中以运行查询

在我的datastax驱动程序中，我给了3个节点的ip作为联系点，我是否需要在CQLsession创建/或我的cassandra节点中进行任何调整，以便它们能够以高并发性进行写入？另外，我可以并行执行多少次写操作？

所有都是update语句，只在主键上没有任何if条件

Answer 1

您看到的超时是由于您的应用程序使集群过载，从而有效地进行了DDoS攻击。

PT2S 是 2 秒的写入超时。总有一天，提交日志磁盘只能接受这么多的写入IO。如果您在日志或 nodetool tpstats 中看到丢弃的突变，则表明提交日志无法跟上写入速度。

如果您的群集可以支持每秒10K写入次数，但您的应用程序正在进行20K次写入，则您需要将群集的大小翻倍(添加更多节点)以支持吞吐量要求。干杯！