Czy ponowne odtworzenie burzy jest krotką, które przetwarzanie zostało przekroczone?

Question

Zostało wspomniane w dokumentacji sztormowej, że burza powtarza krotkę, która przerwała przetwarzanie. Moje pytanie brzmi: czy burza zrobi to automatycznie (bez wywoływania fail() na wylewce początkowej), czy raczej jest odpowiedzialna za dziób początkowy, aby powtórzyć krotkę (wywoływana jest funkcja fail() i odtwarzanie powinno być zaimplementowane wewnątrz lub nawet gdzieś zewnętrznie)?

Answer 1

Aby uzyskać poprawne odtwarzanie po upływie limitu czasu, musisz zakotwiczyć krotkę z identyfikatorem, gdy emitujesz go z dziobka. Kiedy upłynie limit czasu, to, co zostało użyte jako kotwica, zostanie zwrócone do metody fail (fail (object anchorId)). Teraz możesz użyć anchorId z nieudanej/timeoutout tuple, aby powtórzyć grę lub cokolwiek innego, co chcesz zrobić z krotką timeout. Każdy identyfikator kotwicy musi być niepowtarzalny. Przykładem identyfikatora zakotwiczenia jest identyfikator bazy danych. Kiedy krotka nie powiedzie się, możesz użyć identyfikatora bazy danych, aby odtworzyć krotkę i ponownie ją wydać. Aby odpowiedzieć na twoje pytanie, musisz mieć logikę powtórki w niepowodzeniu i możesz użyć anchorId do odtworzenia swojej krotki. Mam nadzieję, że ta informacja pomaga

Answer 2

Od http://storm.apache.org/documentation/Guaranteeing-message-processing.html,

jeśli Storm krotkowe razy-out będzie wywołać metodę fail na Spout

Więc tak, fail zostanie wywołana.