The RPC methods `heartbeatFromXYZ` are the incoming heartbeats from the
JobMaster and ResourceManager, respectively. That's why they are called
heartbeatFrom. The TaskExecutor is only responding to heartbeat requests
but not actively sending them out.
Cheers,
Till
On Thu, Feb 8, 2018 at 1:06 PM, mingleizhang <zml13856086...@163.com> wrote:
> Attached is the taskmanager design picture. And from the picturen, I know
> taskmanager send heartbeat to jobmanager ( also called jobmaster in flip6
> now) and resourcesmanager periodically. But when I watched the source code
> below in TaskExecutor.java. I feel confused about the function name.
> Shouldn't it be *heartbeatToJobManager *and *heartbeatToResouceManager *?
> And in TaskExecutorGateway.java there is a comment, Heartbeat request from
> job manager. yea. both them confused me a lot. Does anyone let me know why
> called it like that ?
>
> Thanks
> Rice.
>
> // ----------------------------------------------------------------------
> // Heartbeat RPC
> // ----------------------------------------------------------------------
>
> @Override
> public void heartbeatFromJobManager(ResourceID resourceID) {
> jobManagerHeartbeatManager.requestHeartbeat(resourceID, null);
> }
>
> @Override
> public void heartbeatFromResourceManager(ResourceID resourceID) {
> resourceManagerHeartbeatManager.requestHeartbeat(resourceID, null);
> }
>
> /**
> * Heartbeat request from the job manager.
> *
> * @param heartbeatOrigin unique id of the job manager
> */
> void heartbeatFromJobManager(ResourceID heartbeatOrigin);
>
> /**
> * Heartbeat request from the resource manager.
> *
> * @param heartbeatOrigin unique id of the resource manager
> */
> void heartbeatFromResourceManager(ResourceID heartbeatOrigin);
>
>
>
>
>
