Cassandra DataStax 5.0 после обновления сбой чтения QueryQueries - PullRequest
0 голосов
/ 04 декабря 2018

Недавно мы перешли с cassandra 4.x datastax на cassandra 5.1.4.Мы используем thriftQueries для записи и чтения данных для 4.x.После обновления мы смогли записать данные на Кассандре, но когда мы пытаемся получить данные, происходит сбой.В чем может быть причина?Пожалуйста, найдите прикрепленные журналы ниже.


[2018-11-16T20: 34: 29.020Z] ОШИБКА [L: nemo.interactions.indexer.impl.consumer.ContextVariableSearchConsumer T: 'pool-14-thread-8 'I: TR: SQ: ND:] - Ошибка в потреблении контекстных событий com.tfsc.ilabs.chronos.core.api.exceptions.ChronosFatalException: com.tfsc.ilabs.chronos.core.cassandra.api.exceptions.CassandraFatalExcection: 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), попытки = 3] Превышено время ожидания подключения по адресу com.tfsc.ilabs.chronos.queue.consumer.impl.ChronosEventPartitionConsumer.getAllEvents (ChronosEventPartitionConsumer.java:275) ~ [?:?] на com.tfsc.ilabs.nemo.interactions.indexer.impl.consumer.ContextVariableSearchConsumer.run (ContextVariableSearchConsumer.java:181) [com.tfsc.ilabs.nemo.interactions.indexer_2.29.0.201810080618.j.jar: jar:concurrent.Executors $ RunnableAdapter.call (Executors.java:511) [?: 1.8.0_172] в java.util.concurrent.FutureTask.runAndReset (FutureTask.java:308) [?: 1.8.0_172] в java.util.concurrent.ScheduledThreadPoolExecutor $ScheduledFutureTask.access $ 301 (ScheduledThreadPoolExecutor.java:180) [?: 1.8.0_ 172] в java.util.concurrent.ScheduledThreadPoolExecutor $ ScheduledFutureTask.run (ScheduledThreadPoolExecutor.java:294) [2]:?concurrent.ThreadPoolExecutor.runWorker (ThreadPoolExecutor.java:1149) [?: 1.8.0_172] в java.util.concurrent.ThreadPoolExecutor $ Worker.run (ThreadPoolExecutor.java:624) [?: 1.8.0_172] в Java.Thread.run (Thread.java:748) [?: 1.8.0_172] Вызывается: 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, латентность = 1998 (1998), попытки = 3] Превышено время ожидания подключения к тел.tfsc.ilabs.chronos.core.cassandra.impl.CassandraClientImpl._fetchRows (CassandraClientImpl.java:582) ~ [?:?] в com.tfsc.ilabs.chronos.core.cassandra.impl.CassandraClientImpl.fetchRowsCraj??] at com.tfsc.ilabs.chronos.queue.consumer.impl.ChronosEventPartitionConsumer.getAllEvents (ChronosEventPartitionConsumer.java:244) ~ [?:?] ... еще 8

...