【问题标题】：Flink Cassandra Time out ErrorFlink Cassandra 超时错误
【发布时间】：2017-10-02 20:56:33
【问题描述】：
我正在研究 Kafka Flink Cassandra Sink。 Flink 代码可以正常工作近 4 个小时。在那之后，我得到了一个例外。
原因：com.datastax.driver.core.exceptions.WriteTimeoutException：在一致性 LOCAL_ONE 写入查询期间 Cassandra 超时（需要 1 个副本，但只有 0 个确认写入）
谁能帮忙？
【问题讨论】：
标签：
apache-kafka
apache-flink
cassandra-2.1
【解决方案1】：
这与 Flink 无关，而是与 Cassandra 相关：您可能在 Cassandra 中写得太快了。检查分配给 Cassandra 的 RAM 数量、CPU 数量......
【解决方案2】：
C* 没有响应客户端可能是因为
- C* 正在执行 GC；如果您启用了它，您可以检查 gc.log。 C* 在执行 GC 时也可能具有高 CPU
- 如果磁盘写入吞吐量跟不上传入数据。您可能会看到提交日志堆积如山。在正常情况下，一旦数据刷新到磁盘，提交日志就应该被回收。
此外，我建议检查您对 RF# 的设置以及写入/读取查询的一致性级别。如果有另一个可用的副本（RF = 2+），您可能有机会从空闲节点检索数据副本。