Cassandra数据税务一致性级别问题

Question

我正在为我的应用程序创建一个cassandra会话对象，并为它创建一些准备好的语句。对每个准备好的语句设置不同的一致性级别。

statement1 = session.prepare("SELECT key FROM foo WHERE key = ?");
statement1.setConsistencyLevel(ConsistencyLevel.LOCAL_QUORUM);

statement2 = session.prepare("SELECT key FROM foo WHERE key = ?");
statement2.setConsistencyLevel(ConsistencyLevel.QUORUM);

我们之前只有statement1，cassandra读取延迟小于10ms。当我们添加statement2并从代码的一部分开始使用它时，每次cassandra调用的延迟都会增加到250ms。

这是datastax中的错误吗？有没有可能

statement2.setConsistencyLevel(ConsistencyLevel.QUORUM);

正在将一致性级别设置为一致性级别。整个会话的法定人数？

我错过了一些愚蠢的东西吗？

我用的是Cassandra-driver-core-3 . 1 . 3 . jar

Answer 1

溶液：

statement1 = session.prepare("SELECT key FROM foo WHERE key = ?");
statement2 = session.prepare("SELECT key FROM foo WHERE key = ?");

这两个预准备语句完全相同，这意味着查询字符串是相同的：“从 foo 中选择键，其中键 = ？”

cassandra datastax驱动器已进行了优化。因此，当您创建第二条语句时，datastax驱动程序将返回第一条语句的引用。因此

statement2.setConsistencyLevel(ConsistencyLevel.QUORUM);

最终在第一条语句上设置一致性级别。

此问题的解决方案是在绑定语句上设置一致性级别，而不是在预准备语句上设置一致性级别。

例如:

statement1 = session.prepare("SELECT key FROM foo WHERE key = ?");
BoundStatement boundStatement = new BoundStatement(statement1); 
boundStatement.setConsistencyLevel(ConsistencyLevel.QUORUM);