Hi,
As I’m investigating onto Flink’s fault tolerance capabilities, I would like to
know what component and class is in charge of TaskManager failure detection and
checkpoint restoring? In addition, how does Flink actually determine that a
TaskManager has failed due to e.g. hardware failures
:user
主 题:TaskManager failure detection
Hi,
As I’m investigating onto Flink’s fault tolerance capabilities, I would like to
know what component and class is in charge of TaskManager failure detection and
checkpoint restoring? In addition, how does Flink actually determine that a
TaskManager has fai