1

我在使用 spark 连接器在 aws 键空间上写入数据时遇到问题。下面的这条消息显示：

ERROR QueryExecutor: Failed to execute: com.datastax.spark.connector.writer.RichBoundStatementWrapper@681c47f5 com.datastax.oss.driver.api.core.servererrors.WriteTimeoutException: Cassandra timeout during SIMPLE write query at consistency LOCAL_QUORUM (2 replica were required but only 0 acknowledged the write)

Spark 版本：3.1 EMR：6.3.1 Cassandra：3.11.2

4

2 回答 2

1

当您收到 Amazon Keyspaces 的 WriteTimeout 错误时，通常表示写入请求因容量不足而失败。为了提供更多信息，我们建议使用我们在 Github 上放置的 Cloud Watch Monitoring 模板：https ://github.com/aws-samples/amazon-keyspaces-cloudwatch-cloudformation-templates 。它是一个 Cloud Watch 模板，可帮助您监控资源，来自 Cloud watch 指标的信息将帮助我们确定您收到此错误的原因，以便我们更好地为您提供帮助。

于 2021-09-21T18:48:16.123 回答
0

首先请检查集群上所有节点的负载意味着 IO、CPU 和内存统计信息是否都正常。

作为一种解决方法，您还可以考虑在 cassandra.conf 中增加以下超时参数。write_request_timeout_in_ms & read_request_timeout_in_ms

于 2021-09-16T03:53:41.313 回答