最近我们从4.x datastax cassandra迁移到5.1.4 datastax cassandra . 我们使用thriftQueries来编写和读取4.x的数据 . 升级后我们已经能够在cassandra中写入数据但是当我们尝试获取数据时它失败了 . 可能是什么原因？请在下面找到附件日志 .
[2018-11-16T20:34:29.020Z] ERROR [L:nemo.interactions.indexer.impl.consumer.ContextVariableSearchConsumer T:'pool-14-thread-8' I: TR: SQ: ND:] - Error in consumimg context events com.tfsc.ilabs.chronos.core.api.exceptions.ChronosFatalException: com.tfsc.ilabs.chronos.core.cassandra.api.exceptions.CassandraFatalExcep tion: com.netflix.astyanax.connectionpool.exceptions.PoolTimeoutException: PoolTimeoutException: [host=history-cassandra03.assist-db.stagi ng.va1.247-inc.net(10.67.169.9):9160, latency=1998(1998), attempts=3]Timed out waiting for connection at com.tfsc.ilabs.chronos.queue.consumer.impl.ChronosEventPartitionConsumer.getAllEvents(ChronosEventPartitionConsumer.java:275) ~ [?:?] at com.tfsc.ilabs.nemo.interactions.indexer.impl.consumer.ContextVariableSearchConsumer.run(ContextVariableSearchConsumer.java:181 ) [com.tfsc.ilabs.nemo.interactions.indexer_2.29.0.201810080618.jar:?] at java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:511) [?:1.8.0_172] at java.util.concurrent.FutureTask.runAndReset(FutureTask.java:308) [?:1.8.0_172] at java.util.concurrent.ScheduledThreadPoolExecutor$ScheduledFutureTask.access$301(ScheduledThreadPoolExecutor.java:180) [?:1.8.0_ 172] at java.util.concurrent.ScheduledThreadPoolExecutor$ScheduledFutureTask.run(ScheduledThreadPoolExecutor.java:294) [?:1.8.0_172] at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1149) [?:1.8.0_172] at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624) [?:1.8.0_172] at java.lang.Thread.run(Thread.java:748) [?:1.8.0_172] Caused by: com.tfsc.ilabs.chronos.core.cassandra.api.exceptions.CassandraFatalException: com.netflix.astyanax.connectionpool.exceptions.Po olTimeoutException: PoolTimeoutException: [host=history-cassandra03.assist-db.staging.va1.247-inc.net(10.67.169.9):9160, latency=1998(1998 ), attempts=3]Timed out waiting for connection at com.tfsc.ilabs.chronos.core.cassandra.impl.CassandraClientImpl._fetchRows(CassandraClientImpl.java:582) ~[?:?] at com.tfsc.ilabs.chronos.core.cassandra.impl.CassandraClientImpl.fetchRowsConsistent(CassandraClientImpl.java:560) ~[?:?] at com.tfsc.ilabs.chronos.queue.consumer.impl.ChronosEventPartitionConsumer.getAllEvents(ChronosEventPartitionConsumer.java:244) ~ [?:?] ... 8 more