Операция удаления Cassandra иногда не работает, возможность выбрать данные после удаления

java cassandra datastax cassandra-2.0 datastax-java-driver

924 просмотра

2 ответа

695 Репутация автора

У меня две таблицы

CREATE TABLE IF NOT EXISTS QueueBucket (
    queueName   text,
    bucketId    int,
    scheduledMinute timestamp,
    scheduledTime timestamp,
    messageId   uuid,
    PRIMARY KEY ((queueName, bucketId, scheduledMinute), scheduledTime, messageId)
)  WITH compaction = { 'class' :  'LeveledCompactionStrategy'  } AND speculative_retry='NONE' ;

CREATE TABLE IF NOT EXISTS InDelivery (
    queueName       text,
    nodeId        uuid,
    dequeuedMinute    timestamp,
    messageId       uuid,
    bucketid        int,
    dequeuedTime    timestamp,
    PRIMARY KEY ((queueName, nodeId,bucketId, dequeuedMinute),dequeuedTime, messageId)
);

В коде я выполняю вставку в QueueBucket и удаляю из ресурса в пакетном режиме (в журнале). Но во время нагрузочного тестирования некоторые, как удаление из ресурса иногда не работает, хотя вставка в QueueBucket работает. Чтобы подтвердить это, применяется проверка на чтение и доставку, сразу после которой читается удаленный messageId, если messageId еще существует и печатает журнал WARN.

    queueDao.insertMsgInfo(queueName, bucketId, QueueUtils.getMinute(scheduledTime), scheduledTime, messageId);
    queuDao.deleteInDelivery(queueName, nodeId, bucketId, bucketMinute, dequeuedTime, messageId);
    if(queueServiceMetaDao.hasIndeliveryMessage(inDeliveryPK)) {
        log.warn("messageId  {} of queue {} bucket {} with node {} dequuedTime {} dequeud minute {} could not get deleted from indelivery.",
                messageId,queueName,bucketId, nodeId,QueueUtils.dateToString(dequeuedTime),QueueUtils.dateToString(bucketMinute));
        }

В методах insertMsgInfo и deleteInDelivery я повторно использую подготовленный оператор.

"INSERT INTO queuebucket (queuename, bucketid , scheduledminute, scheduledtime, messageid ) VALUES ( ? , ? , ? , ? , ? );"
"DELETE FROM indelivery WHERE queuename = ? AND nodeId = ? AND bucketId=? AND dequeuedMinute=? AND dequeuedTime =? AND messageId=? ;"

в hasIndeliveryMessage я передаю в inDeliveryPrimaryKey те же значения, которые я передал для удаления данных в методе moveBackToQueueBucket.

"SELECT messageId FROM indelivery WHERE queuename = ? AND nodeId = ? AND bucketId=? AND dequeuedMinute=? AND dequeuedTime=? AND messageId=? ;"

Я понятия не имею, почему я вижу многократное предупреждающее сообщение "не удалось удалить из времени доставки". , Пожалуйста помоги

Я использую Cassandra версии 2.2.7, это кластер Cassandra с 6 узлами с коэффициентом репликации 5, и согласованность чтения и записи используется QUORUM.

Я также прошел по ссылке Cassandra - удаленные данные все еще там и https://issues.apache.org/jira/browse/CASSANDRA-7810, но эта проблема давно устранена. В 2.0.11.

Дальнейшее обновление Согласно Cassandra - удаление не работает, я также запустил восстановление nodetool, но проблема все еще сохраняется. Должен ли я работать компактно, а?

Дальнейшее обновление: я больше не использую пакет, я просто вставляю в очередь и удаляю для доставки, а затем читаю данные, но проблема остается.

Добавление некоторых журналов:

2016-07-19 20:39:42,440[http-nio-8014-exec-12]INFO  QueueDaoImpl -deleting from indelivery queueName pac01_deferred nodeid 1349d57f-28f5-37d4-9fe1-dfa14dba4a9f bucketId 382 dequeuedMinute 20160719203900000 dequeuedTime 20160719203942310 messageId cc4fb158-f61e-345b-8dcf-3f842fe52d50:
2016-07-19 20:39:42,442[http-nio-8014-exec-12]INFO  QueueDaoImpl -Reading from indelivery : queue pac01_deferred nodeId 1349d57f-28f5-37d4-9fe1-dfa14dba4a9f dequeueMinute 20160719203900000 dequeueTime 20160719203942310 messageid cc4fb158-f61e-345b-8dcf-3f842fe52d50 bucketId 382 indeliveryRow Row[cc4fb158-f61e-345b-8dcf-3f842fe52d50]
2016-07-19 20:39:42,442[http-nio-8014-exec-12]WARN  QueueImpl -messageId  cc4fb158-f61e-345b-8dcf-3f842fe52d50 of queue pac01_deferred bucket 382 with node 1349d57f-28f5-37d4-9fe1-dfa14dba4a9f dequuedTime 20160719203942310 dequeud minute 20160719203900000 could not get deleted from indelivery .

Должен ли я попробовать будет всеобщее согласие ???

Автор: Laxmikant Источник Размещён: 19.07.2016 08:19

Ответы (2)


1 плюс

38452 Репутация автора

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

Что касается вашей реальной проблемы, я видел это раньше с моделями, которые используют метки времени в качестве ключей. Как вы создаете значения меток времени для dequeuedMinuteи dequeuedTime?

Если вы сами собираете временные метки, то их удаление должно быть простым. Однако, если вы создаете их с помощью dateOf(now())или Java.Util.Dateтогда у ваших временных меток будут храниться миллисекунды с ними. Хотя cqlsh замаскирует это от вас:

INSERT INTO InDelivery (queuename, nodeid, bucketid , dequeuedMinute, dequeuedTime, messageid )
VALUES ('test1',uuid(),2112,dateof(now()),dateof(now()),uuid());

INSERT INTO InDelivery (queuename, nodeid, bucketid , dequeuedMinute, dequeuedTime, messageid )
VALUES ('test1',a24e056a-94fa-4aee-b3a7-a8df6060091a,2112,'2016-07-19 09:57:16-0500','2016-07-19 09:57:16-0500',uuid());

SELECT queuename,nodeid,dequeuedMinute,blobasbigint(timestampasblob(dequeuedMinute)),             
dequeuedTime,blobasbigint(timestampasblob(dequeuedTime)),messageid
FROM InDelivery;

 queuename | nodeid                               | dequeuedMinute                | blobasbigint(timestampasblob(dequeuedMinute)) | dequeuedTime             | blobasbigint(timestampasblob(dequeuedTime)) | messageid
-----------|--------------------------------------+-------------------------------+-----------------------------------------------+--------------------------+--------------------------------------+---------------------------------------------
     test1 | a24e056a-94fa-4aee-b3a7-a8df6060091a | 2112 2016-07-19 09:57:16-0500 |                                 1468940236000 | 2016-07-19 09:57:16-0500 |                               1468940236000 | 7ca1f676-9034-45ba-bb3f-377ba74cc5c0
     test1 | a24e056a-94fa-4aee-b3a7-a8df6060091a | 2112 2016-07-19 09:57:16-0500 |                                 1468940236641 | 2016-07-19 09:57:16-0500 |                               1468940236641 | 9721d96e-d6f5-43a7-9ba4-18ef4d54ab8a
(2 rows)

Эти метки времени выглядят одинаково, верно? Но применение blobasbigint(timestampasblob(вложенных функций показывает разницу (000 против 641 миллисекунд).

Обратите внимание, что если я изменю свой SELECTфильтр на 641 миллисекунду (последние 3 цифры в blobasbigint(timestampasblob(столбцах), я получу строку с миллисекундами.

SELECT queuename,nodeid,dequeuedMinute,blobasbigint(timestampasblob(dequeuedMinute)),             
dequeuedTime,blobasbigint(timestampasblob(dequeuedTime)),messageid
FROM InDelivery
WHERE queuename='test1' AND bucketid=2112 
AND nodeid=a24e056a-94fa-4aee-b3a7-a8df6060091a
AND dequeuedMinute='2016-07-19 09:57:16.641-0500';

 queuename | nodeid                               | dequeuedMinute                | blobasbigint(timestampasblob(dequeuedMinute)) | dequeuedTime             | blobasbigint(timestampasblob(dequeuedTime)) | messageid
-----------|--------------------------------------+-------------------------------+-----------------------------------------------+--------------------------+--------------------------------------+---------------------------------------------
     test1 | a24e056a-94fa-4aee-b3a7-a8df6060091a | 2112 2016-07-19 09:57:16-0500 |                                 1468940236641 | 2016-07-19 09:57:16-0500 |                               1468940236641 | 9721d96e-d6f5-43a7-9ba4-18ef4d54ab8a
(1 rows)

Суть в том, что если вы собираетесь хранить миллисекунды с вашими временными метками, то вам также необходимо включить их, когда вы SELECT/DELETEпользуетесь этими клавишами. Точно так же, если вы не храните миллисекунды на клавишах отметок времени, вы не можете включать их, когда SELECT/DELETEиспользуете эти клавиши.

Автор: Aaron Размещён: 19.07.2016 03:55

1 плюс

695 Репутация автора

Использование TIMESTAMP на стороне клиента решило мою проблему. Спасибо Михаилу Бакшееву за указание.

Рекомендуется использовать его со стороны клиента в запросе, чтобы поддерживать порядок мутации.

Если мы вставляем и удаляем данные, убедитесь, что значение TIMESTAMP, которое мы передаем в запросе на удаление, должно быть больше, чем мы передали при вставке.

Другие причины сбоя удаления данных / сбой в Кассандаре могут быть

  1. игнорирование значения в миллисекундах при удалении для поля метки времени.
  2. Данные могут появиться снова, если узел не работает дольше, чем льготный период.
Автор: Laxmikant Размещён: 31.08.2016 03:13
Вопросы из категории :
32x32