一致性级别 ALL 使用 while statement has consistency level TWO defined

Question

我们使用 java datastax cassandra 驱动程序 2.1.2。我们使用的 Cassandra 版本是 2.0.9.

我们有使用 QueryBuilder 构建的语句，我们正在明确地将一致性级别设置为 TWO 上的语句。

Select selectStatement =  QueryBuilder.select().from(ARTICLES);
selectStatement.where(eq(ORGANIZATION_ID, organizationId));
selectStatement.setConsistencyLevel(ConsistencyLevel.TWO);

final ResultSet rs = session.execute(selectStatement);
//call to all() will be removed since it is enough to iterate over result set 
//and then you get pagination for free instead of loading everything in 
//memory
List<Row> rows = rs.all();  
for (final Row row : rows) {
   //do something with Row, convert to POJO
}

我们得到这样的异常：

com.datastax.driver.core.exceptions.ReadTimeoutException: Cassandra timeout during read query at consistency ALL (3 responses were required but only 2 replica responded)
com.datastax.driver.core.exceptions.ReadTimeoutException.copy (ReadTimeoutException.java:69)
com.datastax.driver.core.DefaultResultSetFuture.extractCauseFromExecutionException (DefaultResultSetFuture.java:259)
com.datastax.driver.core.ArrayBackedResultSet$MultiPage.prepareNextRow (ArrayBackedResultSet.java:279)
com.datastax.driver.core.ArrayBackedResultSet$MultiPage.isExhausted (ArrayBackedResultSet.java:239)
com.datastax.driver.core.ArrayBackedResultSet.hasNext (ArrayBackedResultSet.java:122)
com.datastax.driver.core.ArrayBackedResultSet.all (ArrayBackedResultSet.java:111)

我知道在 ResultSet 上调用 all() 会使它在内存中加载所有用于组织的文章并使用它并在 cassandra 上创建负载。如评论中所述，这将被删除。这可能会导致读取超时，但我仍然不明白为什么在异常消息中有 ALL.

问题是为什么当我们将原始语句设置为TWO时，异常告诉我们使用一致性级别ALL。 all() 是否在内部使用查询并默认使用 CL ALL？

Answer 1

您的问题几乎可以肯定是 https://issues.apache.org/jira/browse/CASSANDRA-7947。您会看到一条错误消息，表示无法执行读取修复。它与您原来的一致性级别无关。这在 2.1.3+ 中已修复。

一致性级别 ALL 使用 while statement has consistency level TWO defined

Consistency level ALL used while statement has consistency level TWO defined

java

cassandra

datastax-java-driver

cassandra-2.1