Spring Data Cassandra 的异常答案

【问题标题】：Exception with Spring Data CassandraSpring Data Cassandra 的异常
【发布时间】：2021-08-19 21:59:46
【问题描述】：

我在使用 Spring-Data-Cassandra 查询 cassandra 时遇到异常。请帮忙 2021-06-01 12:09:48.594 INFO 9568 --- [nio-8080-exec-3] c.e.demo2.Controller.DemoController：错误：org.springframework.data.cassandra.CassandraUncategorizedException：查询； CQL [select * from summary_data where proj_id = ?和类别 = ?和名字=？和时间 >= ?]; PT10S 后查询超时；嵌套异常为 com.datastax.oss.driver.api.core.DriverTimeoutException: PT10S 后查询超时

private final AsyncCassandraOperations asyncCassandraTemplate;

public List<Data1> getData(String convProjectId, List<String> stageNames,
        String eventCategory, List<String> distinctDateHour) {
    final String cql = "select * from summary_data where proj_id = ? and category = ? and name = ? and time >= ?";
    List<BanEventLifecycle> bList = new ArrayList<>();
    ArrayList<ListenableFuture<List<Data1>>> bFutureList = new ArrayList<>();
    distinctDateHour.forEach(dateHr-> stageNames.forEach(stageName->{
        ListenableFuture<List<Data1>> futureBData = asyncCassandraTemplate.getAsyncCqlOperations().query(cql,
                ps -> ps.bind().setString(0, projectId.toLowerCase()).setString(1,dateHr)
                        .setString(2, category.toLowerCase()).setString(3, name),
                (row, rowNum) -> Data1.getData1(row));
        bFutureList.add(futureBData);
    }));
    bFutureList.forEach(future -> {
        try {
            banList.addAll(future.get());
        } catch (Exception exception) {
        }
    });
    return bList;
}

Spring-Data-Cassandra：3.0.9.RELEASE

【问题讨论】：

标签： spring-boot cassandra datastax-java-driver spring-data-cassandra

【解决方案1】：

当 Cassandra 的 Java 驱动程序在驱动程序请求超时（您的情况是 10 秒 (PT10S) 内没有从协调器返回响应时，它会抛出 DriverTimeoutException。

您需要查看 Cassandra 日志以确定协调员未响应司机请求的原因。要么您正在执行昂贵的查询，要么当时集群过载。

请注意，您不应将DriverTimeoutException 与ReadTimeoutException 混淆，后者是协调器在读取请求超时内未收到来自副本的响应时引发的错误。干杯！

【讨论】：