1

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 の実装が変更されたのでしょうか?

ありがとう

4

0 に答える 0