试图在 Cassandra 中实现触发器。
一直在尝试使用可用的 Cassandra 帮助:https ://github.com/hmsonline/cassandra-triggers 将其移植到最新版本 1.2.3,并遵循GettingStarted说明。
当我尝试设置触发器的值,插入数据以触发日志并检查日志时,以下是我收到的错误
java.lang.AssertionError
at org.apache.cassandra.thrift.ThriftSessionManager.currentSession(ThriftSessionManager.java:51) at org.apache.cassandra.thrift.CassandraServer.state(CassandraServer.java:88) at org.apache.cassandra.thrift.CassandraServer.validateLogin(CassandraServer.java:881) at org.apache.cassandra.thrift.CassandraServer.set_keyspace(CassandraServer.java:1492) at com.hmsonline.cassandra.triggers.dao.CassandraStore.getConnection(CassandraStore.java:42) at com.hmsonline.cassandra.triggers.dao.ConfigurationStore.getConfiguration(ConfigurationStore.java:76) at com.hmsonline.cassandra.triggers.dao.ConfigurationStore.isCommitLogEnabled(ConfigurationStore.java:44) at com.hmsonline.cassandra.triggers.TriggerTask.run(TriggerTask.java:47) at java.lang.Thread.run(Thread.java:636)
但我们测试它在旧版本中运行良好(例如:1.1.2)
那么这是配置问题,还是 Thrift API 实现已更改?
谢谢