TimeWindowCompactionStrategy Как это работает. когда счетчик времени запускается после создания - PullRequest
Новая
       12

TimeWindowCompactionStrategy Как это работает. когда счетчик времени запускается после создания

1 голос
/ 05 апреля 2019

У меня есть таблица Кассандры, использующая TWCS с временным окном в 1 день, что означает, что сжатие будет выполнено через 1 дневное окно.Итак, теперь мой вопрос состоит в том, как Кассандра решит, когда сжатие будет выполнено в самый первый раз -

1) Ровно через 1 день, когда таблица была создана, как я создал таблицу в 10:00 (IST) в1 апреля, так что сжатие начнется в 10:00 утра 2 апреля. 2) Это начинается с 00:00 часов, что означает, что каждый день в 00:00 часов будет начинаться уплотнение.

Мне нужно это понятьКонцепция, как всякий раз, когда я делаю запрос на чтение в журналах трассировки таблиц, показывает, что данные поступают из нескольких SSTable, мне нужно знать, почему?Мой ключ раздела таблицы - SensorID и дата.Таким образом, согласно концепции весь ключ раздела хранится на одном узле.Итак, в идеале весь раздел должен быть из одного SSTable.Я поделюсь журналом трассировки, чтобы получить ясность. 

Tracing session: 5ddecd60-546a-11e9-83a5-4bbd3b5675f1

 activity                                                                                                                              | timestamp                  | source      | source_elapsed | client
---------------------------------------------------------------------------------------------------------------------------------------+----------------------------+-------------+----------------+-------------
                                                                                                                    Execute CQL3 query | 2019-04-01 10:39:02.966000 | 192.168.0.2 |              0 | 192.168.0.2
                                                      READ message received from /192.168.0.2 [MessagingService-Incoming-/192.168.0.2] | 2019-04-01 10:39:01.915000 | 192.168.0.3 |             74 | 192.168.0.2
                                                                    Executing single-partition query on locationinfohash [ReadStage-1] | 2019-04-01 10:39:01.916000 | 192.168.0.3 |            380 | 192.168.0.2
                                                                                            Acquiring sstable references [ReadStage-1] | 2019-04-01 10:39:01.916000 | 192.168.0.3 |            452 | 192.168.0.2
                                                                    Partition index with 0 entries found for sstable 112 [ReadStage-1] | 2019-04-01 10:39:01.916000 | 192.168.0.3 |            588 | 192.168.0.2
                                                                    Partition index with 0 entries found for sstable 111 [ReadStage-1] | 2019-04-01 10:39:01.916000 | 192.168.0.3 |            900 | 192.168.0.2
                                                                    Partition index with 0 entries found for sstable 110 [ReadStage-1] | 2019-04-01 10:39:01.916000 | 192.168.0.3 |           1177 | 192.168.0.2
                                                                     Partition index with 0 entries found for sstable 89 [ReadStage-1] | 2019-04-01 10:39:01.917000 | 192.168.0.3 |           1466 | 192.168.0.2
                                                                                            Key cache hit for sstable 52 [ReadStage-1] | 2019-04-01 10:39:01.917000 | 192.168.0.3 |           1673 | 192.168.0.2
                                               Skipped 0/5 non-slice-intersecting sstables, included 0 due to tombstones [ReadStage-1] | 2019-04-01 10:39:01.917000 | 192.168.0.3 |           1726 | 192.168.0.2
                                                                               Merged data from memtables and 5 sstables [ReadStage-1] | 2019-04-01 10:39:01.922000 | 192.168.0.3 |           6639 | 192.168.0.2
                                                                                Read 100 live rows and 0 tombstone cells [ReadStage-1] | 2019-04-01 10:39:01.922000 | 192.168.0.3 |           6854 | 192.168.0.2
                                                                                      Enqueuing response to /192.168.0.2 [ReadStage-1] | 2019-04-01 10:39:01.922000 | 192.168.0.3 |           6926 | 192.168.0.2
                                       Sending REQUEST_RESPONSE message to /192.168.0.2 [MessagingService-Outgoing-/192.168.0.2-Small] | 2019-04-01 10:39:01.922000 | 192.168.0.3 |           7181 | 192.168.0.2
                                                      READ message received from /192.168.0.2 [MessagingService-Incoming-/192.168.0.2] | 2019-04-01 10:39:02.186000 | 192.168.0.1 |             42 | 192.168.0.2
                                                                    Executing single-partition query on locationinfohash [ReadStage-6] | 2019-04-01 10:39:02.187000 | 192.168.0.1 |            824 | 192.168.0.2
                                                                                            Acquiring sstable references [ReadStage-6] | 2019-04-01 10:39:02.187000 | 192.168.0.1 |            967 | 192.168.0.2
                                                                     Partition index with 0 entries found for sstable 68 [ReadStage-6] | 2019-04-01 10:39:02.187000 | 192.168.0.1 |           1135 | 192.168.0.2
                                                                     Partition index with 0 entries found for sstable 67 [ReadStage-6] | 2019-04-01 10:39:02.187001 | 192.168.0.1 |           1437 | 192.168.0.2
                                                                     Partition index with 0 entries found for sstable 66 [ReadStage-6] | 2019-04-01 10:39:02.188000 | 192.168.0.1 |           1863 | 192.168.0.2
                                                                                            Key cache hit for sstable 45 [ReadStage-6] | 2019-04-01 10:39:02.188000 | 192.168.0.1 |           2277 | 192.168.0.2
                                               Skipped 0/4 non-slice-intersecting sstables, included 0 due to tombstones [ReadStage-6] | 2019-04-01 10:39:02.188000 | 192.168.0.1 |           2354 | 192.168.0.2
                                                                               Merged data from memtables and 4 sstables [ReadStage-6] | 2019-04-01 10:39:02.194000 | 192.168.0.1 |           8300 | 192.168.0.2
                                                                                Read 100 live rows and 0 tombstone cells [ReadStage-6] | 2019-04-01 10:39:02.195000 | 192.168.0.1 |           8529 | 192.168.0.2
                                                                                      Enqueuing response to /192.168.0.2 [ReadStage-6] | 2019-04-01 10:39:02.195000 | 192.168.0.1 |           8599 | 192.168.0.2
                                       Sending REQUEST_RESPONSE message to /192.168.0.2 [MessagingService-Outgoing-/192.168.0.2-Small] | 2019-04-01 10:39:02.195000 | 192.168.0.1 |           8908 | 192.168.0.2
 Parsing select * from trackfleet_db.locationinfohash where pkhash = '34AAB6D5F1431151211AF721F951057F'; [Native-Transport-Requests-1] | 2019-04-01 10:39:02.966000 | 192.168.0.2 |            140 | 192.168.0.2
                                                                                     Preparing statement [Native-Transport-Requests-1] | 2019-04-01 10:39:02.966000 | 192.168.0.2 |            219 | 192.168.0.2
                                                                          reading data from /192.168.0.1 [Native-Transport-Requests-1] | 2019-04-01 10:39:02.966000 | 192.168.0.2 |            401 | 192.168.0.2
                                                                  speculating read retry on /192.168.0.3 [Native-Transport-Requests-1] | 2019-04-01 10:39:02.967000 | 192.168.0.2 |            462 | 192.168.0.2
                                                   Sending READ message to /192.168.0.1 [MessagingService-Outgoing-/192.168.0.1-Small] | 2019-04-01 10:39:02.967000 | 192.168.0.2 |            504 | 192.168.0.2
                                                   Sending READ message to /192.168.0.3 [MessagingService-Outgoing-/192.168.0.3-Small] | 2019-04-01 10:39:02.967000 | 192.168.0.2 |            558 | 192.168.0.2
                                          REQUEST_RESPONSE message received from /192.168.0.3 [MessagingService-Incoming-/192.168.0.3] | 2019-04-01 10:39:02.976000 | 192.168.0.2 |           9643 | 192.168.0.2
                                                                       Processing response from /192.168.0.3 [RequestResponseStage-16] | 2019-04-01 10:39:02.976000 | 192.168.0.2 |           9700 | 192.168.0.2
                                          REQUEST_RESPONSE message received from /192.168.0.1 [MessagingService-Incoming-/192.168.0.1] | 2019-04-01 10:39:02.976000 | 192.168.0.2 |          10372 | 192.168.0.2
                                                                       Processing response from /192.168.0.1 [RequestResponseStage-10] | 2019-04-01 10:39:02.977000 | 192.168.0.2 |          10447 | 192.168.0.2
                                                                                      Initiating read-repair [RequestResponseStage-10] | 2019-04-01 10:39:02.977000 | 192.168.0.2 |          10479 | 192.168.0.2
                                                                                                                      Request complete | 2019-04-01 10:39:02.976914 | 192.168.0.2 |          10914 | 192.168.0.2

Нужно объяснить, почему он читает из SSTable и как работает сжатие TWCS и как мы можем его настроить?

...