Я тоже сталкиваюсь с той же проблемой. У тебя есть решение?

, Я надеюсь, что такая же реализация предусмотрена и для Scala.

учаю данные откуда-то и вставляю их вcassandra ежедневно, то мне нужно получить данные изcassandra на целую неделю и сделать некоторую обработку и вставить результат обратно наcassandra. У меня много записей, каждая из которых выполняет ...

Неверная статистика задержек Cassandra 3.0

Можете ли вы уточнить, урезали ли вы прошлые данные? Он проходит циклы уплотнения, поэтому, несмотря на то, что ваше приложение фактически не обращается к ним, Cassandra есть. Я надеюсь, что для свойства cassandra.yaml auto_snapshot установлено значение по умолчанию true, что означает, что если вы уроните таблицу, она сохранит снимок. Таким образом, Cassandra и приложение больше не получают к нему доступ. Это может быть временное падение, пока вы не протестируете приложение.

я есть 5-узловый кластер Cassandra с ~ 650 ГБ данных на каждом узле с коэффициентом репликации 3. Недавно я начал видеть следующую ошибку в /var/log/cassandra/system.log. ИНФОРМАЦИЯ [ReadStage-5] 2017-10-17 17: 06: 07,887 NoSpamLogger.java:91 ...

Что такое туалет? Вы имели в виду уровень согласованности (CL)? При использовании RF = 3 это означает, что все данные реплицируются 3 раза, и каждый из 3 узлов содержит ВСЕ данные ваших БД. Это означает, что любой запрос к этому разделу может быть обслужен с любого из 3 узлов. Согласно CL (1, Q, ALL), Координатор должен получить ответ от 1/2/3 серверов. В «ВСЕХ» осведомленность сети Snitch не имеет значения, но в CL = Q (2 узла должны ответить), Snitch помогает Координатору выбрать самые быстрые 2 узла. Самый быстрый получит запрос данных и 2-й запрос дайджеста. Кольцо также для целей HA.

я есть 3 узла настройки, Node1 (172.30.56.60), Node2 (172.30.56.61) и Node3 (172.30.56.62). Он имеет данные одного раздела 100K, раздел обрамлен nodeip. Найдите значение токена / раздела для nodeip - 172.30.56.60 cqlsh:qnapstat> SELECT ...

Спасибо @YCF_L за помощь.

My sample cassandra table looks like id | article_read | last_hours | name ----+----------------------------------- 5 | [4, 5, 6] | 5 | shashank 10 | [12, 88, 32] | 1 | sam 8 | [4, 5, 6] | 8 | aman 7 | [5, 6] | 7 | ashif 6 | [4, 5, 6] | 6 | amit ...

Все время заблокировано является мерой того, сколько задач было заблокировано с момента последнего запуска Cassandra, уменьшать не имеет смысла. Вам не нужно, но это может помочь. Это может быть причиной истечения времени ожидания запроса, но неправильный запрос / таблица также могут быть причиной его блокировки. Посмотрите на прокси-гистограммы и гистограммы таблиц, чтобы найти таблицу с медленными запросами и отладку оттуда. Оптимальное значение: зависит от того, было ли единственное оптимальное значение, оно будет установлено на него. Это зависит от варианта использования и модели данных.

ой ссылке я получил несколько замечаний по поводу запросов на транспортировку в Кассандре:Каковы местные транспортные запросы в Кассандре? [https://stackoverflow.com/questions/32456843/what-are-native-transport-requests-in-cassandra] Насколько я ...

 для дальнейшей информации

жно, это особый вопрос, но возможно ли определить узел (ы) ключа разделения? пример: у меня есть идентификатор ключа раздела (int), и я использую ...

, После этого каждый раз, когда вы пытаетесь запустить, вы видите следующую опцию jvm, которую вы должны прокомментировать. 10-15 минут и вуаля.

я совершенно новая установка Windows 10 Home с совершенно новой установкой JDK 10.0.1 (что рекомендовано Oracle, когда я заходил на сайт загрузки JDK). Я только что скачал Cassandra 3.11.2, un-tar ' Сделайте это и поместите каталог bin в мой ...

Также Вы думаете, что модель данных, которую я использовал, является правильным выбором?

я есть модель данных, как показано ниже, CREATE TABLE appstat.nodedata ( nodeip text, timestamp timestamp, flashmode text, physicalusage int, readbw int, readiops int, totalcapacity int, writebw int, writeiops int, writelatency int, PRIMARY KEY ...