Порядок восстановления Flink - PullRequest
0 голосов
/ 15 апреля 2019

Я хочу узнать некоторые подробности о фазе восстановления flink.Операторы самостоятельно загружают состояние и затем восстанавливаются?Или в порядке оператора топологии сначала загрузить состояние из источника по порядку, а затем восстановить?

1 Ответ

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

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

...