95-850-020-源码-心跳-JobMaster与TaskExecutor之间的心跳检测

Posted 2021-10-17 九师兄

文章目录

• 1.概述
• 2.JobMaster与TaskExecutor之间的心跳检测
• • 2.1 初始化过程
  • • 2.1.1 JobMaster启动
  • 2.1.2 TaskExecutor
  • 2.3.注册过程
  • 2.4 心跳过程

1.概述

心跳机制用于检测客户端或者服务端是否存活的一种机制，通过定期向对方发送请求方法，常见的心跳检测有两种：

1. socket 套接字SO_KEEPALIVE本身带有的心跳机制，定期向对方发送心跳包，对方在收到心跳包后会自动回复；
2. 应用自身实现心跳机制，同样也是使用定期发送请求的方式

Flink中ResourceManager、Jo