Problem replikacji Cassandra Data

Question

Mam klaster klastra z 2 węzłami o współczynniku replikacji 2 i AutoBootStrap = true. Wszystko działa dobrze podczas uruchamiania i oba węzły widzą się nawzajem. Nazwijmy te węzły A i B.

1. Dodaj zestaw kluczy i kolumn (pozwala nazwać ten zestaw K1) do Cassandry przez węzeł A.
2. Podłączyć do węzła A i odczytać z powrotem ustawić K1. Sam na Node B. sukces - Dobra
3. proces Zabij Cassandra na Node B.
4. Dodaj ustalonym przez K2 A.
5. Podłączyć do węzła A i czytaj ustawić K2. Dobry
6. Zrestartuj proces Cassandra w węźle B.
7. Spróbuj odczytać wszystkie klucze z B ... ustaw aktualny K1, ustaw K2 BRAK. (Nawet po 30 minutach)
8. Dodaj K3 do A/B.
9. Przeczytaj wszystkie klucze z A - zestaw zwrotów K1, K2, K3
10. Przeczytaj wszystkie klucze z B - zestaw zwrotów K1, K3.

B nigdy nie synchronizuje zestawu K2 ... (minęło więcej niż 12 godzin) Dlaczego węzeł B nie widzi zestawu K2 ... Czy ktoś ma jakiś pomysł?

---

Dodane Info:

Ok ... to był problem. Parametr read_consistency_level był domyślnie ustawiony na wartość 1.

Kiedy więc pytamy węzła B o zestaw K2, i nie ma go (gdy powinien z powodu współczynnika replikacji = 2), natychmiast zwraca błąd "Nie znaleziono".

Jeśli jednak użyjemy spójności odczytu jako QUORUM lub ALL, wówczas B jest zmuszone zapytać A, które następnie zwraca poprawną wartość, a B synchronizuje ten klucz (zapisuje lokalnie).

Prowadzi to do innego problemu - oznacza to, że gdy węzeł B zostanie wyświetlony, nie synchronizuje on wszystkich danych z węzła A nawet po długim czasie. Teraz, jeśli węzeł A ulegnie awarii, w jaki sposób uzyskać dostęp do niezsynchronizowanych danych? (Właśnie testowałem, że nie możemy)

Chyba musi być sposób na wymuszenie synchronizacji danych. Widzę INFO na wyjściu terminalowym, że nastąpiło podpowiedziane przekazanie 15 wierszy od A do B, gdy B podniosło się, ale B nie ma tych wierszy lokalnie (ponieważ wciąż nie możemy odczytać go z B o poziomie spójności JEDNO). Co tu się dzieje?

Answer 1

Istnieją 3 sposoby Cassandra synchronizuje aktualizacje, które zdarzyły się podczas węzeł był w dół:

1. zasugerował przełączanie. wymaga, aby wykrywacz awarii na A rozpoznał, że B jest wyłączone przed napisaniem K2. Zobacz http://wiki.apache.org/cassandra/HintedHandoff
2. odczytać naprawę. wymaga, aby B było podniesione, gdy K2 zostanie poproszony o naprawę. Patrz: Naprawa anty-entropii: http://wiki.apache.org/cassandra/ReadRepair
3. . wymaga wywoływania ręcznego ("naprawa nodetool"). zobacz http://wiki.apache.org/cassandra/AntiEntropy