Bazı özel tetikleyicilerin durumu ve zamanlayıcıları vardır (ör. this example).Apache Flink başarısızlıktan sonra tetik zamanlayıcıları geri yükler mi?
Hatadan sonra durumu will be restored anladığımdan ancak zamanlayıcılar nasıl olur? Arızalardan sonra otomatik olarak geri yüklenecek mi?
Evet zamanlayıcılar, bir arıza durumunda kontrol edilecek ve geri yüklenecektir. Bununla birlikte, burada anlaşılması gereken ince bir ayrıntı vardır. Bir işlem zamanlayıcısını her kaydettiğinizde, WindowOperator, gelecekteki zaman damgasını bir sıraya kaydedecek ve WindowOperator'u tetikleyecek bir zamanlayıcı görevi zamanlayacaktır. Bir WindowOperator tetiklenirse, zaman damgaları geçerli zaman damgasından daha düşük olan tüm kayıtlı zamanlayıcı olaylarını işleyecektir.
Flink yalnızca gelecekteki zaman damgasının sırasını kontrol eder, ancak zamanlanan zamanlayıcı görevlerini denetlemez. Bu, bir kurtarma durumunda, gelecekteki zaman damgalarının sırasını geri yükleyeceğiniz, ancak WindowOperator'u tetikleyen bir zamanlayıcı görevi (zamanlayıcı olayları tetikler) anlamına gelir. Yani yeni bir zamanlayıcı görevi kaydedecek yeni bir eleman için beklemeniz gerekiyor. Bu zamanlayıcı görevi tetiklendiğinde, daha düşük zaman damgalı tüm diğer zamanlayıcı olayları yürütülür.
Bu incelik, WindowOperator, ancak filigranları tetikleyen bir zamanlayıcı göreviniz olmadığından olay zaman işlemesi için geçerli değildir.