2016-08-21 6 views
1

Я заработал 200 миллионов записей в кассандре от искры. Использование разъема spark-cassandra.Кассандра показывает разные результаты в разных сериях

У меня возникли следующие две проблемы. Извините, тема относится только к одному вопросу.

1) com.datastax.driver.core.exceptions.WriteFailureException: Неисправность Кассандры во запросе записи в последовательности LOCAL_QUORUM (1 ответ были необходимы, но только 0 реплики ответил, 1 не удалось)

Я понял, что, имея более высокий коэффициент репликации предпочтительно от 3 позволит решить эту проблему. Я все еще сталкивался с той же проблемой.

Нужно ли мне перезапустить кластер?

2nd & important) Я запустил искра, чтобы сделать count(*) на моем столе. В работе Spark не было ошибок. Однако каждый раз моя работа дает мне разные оценки. Я сильно думаю, что кассандра очень стабильна и прочная. Может быть, я могу пропустить некоторые важные роли здесь.

My actual number of rows: 286,530,307 
My first run result: 285,508,150 
2nd Run: 285,174,293 
3rd Run: 285,232,533 

Почему у меня разные результаты в разных сериях?

My Key Создание пространства:

CREATE KEYSPACE IF NOT EXISTS db_research WITH REPLICATION = { 'class' : 'SimpleStrategy', 'replication_factor' : 3 }; 

Моя таблица имеет 28 столбцов и использовать

Имеет какой-либо один из моих ошибок вызвали такие результаты.? Даже есть ошибки, он должен показывать один и тот же счет каждый раз. Что мне не хватает?

ответ

0

Попробуйте запустить nodetool repair - это будет синхронизировать реплики по кластеру: https://docs.datastax.com/en/cassandra/2.0/cassandra/operations/ops_repair_nodes_c.html

+0

Привет, Когда я использовал nodetool ремонт она принимает навсегда, чтобы закончить. Я урезал стол, а затем сделал ремонт ноделюла. Поскольку данных нет, оно завершается раньше, но когда я снова получаю данные, его та же участь. – Srini

+0

Я также сталкиваюсь с той же проблемой, можете ли вы сообщить мне, поможет ли уплотнение? Я не хочу потерять данные на данный момент. – ashK

Смежные вопросы