Блог

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

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