TaskManager failure detection

2017-02-22 Thread Dominik Safaric
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

回复:TaskManager failure detection

2017-02-22 Thread Zhijiang(wangzhijiang999)
: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