Find such code in the source code based on Heartbeat of TaskManager with id and The heartbeat of ResourceManager with id private class TaskManagerHeartbeatListener implements HeartbeatListener<AccumulatorReport, Void> { private final JobMasterGateway jobMasterGateway; private TaskManagerHeartbeatListener(JobMasterGateway jobMasterGateway) { this.jobMasterGateway = Preconditions.checkNotNull(jobMasterGateway); } @Override public void notifyHeartbeatTimeout(ResourceID resourceID) { jobMasterGateway.disconnectTaskManager( resourceID, new TimeoutException(“Heartbeat of TaskManager with id ” […]
Tag: taskmanager
23. Flink TaskManager memory tuning
Flink TaskManager memory tuning Method: After stress testing and determining the degree of parallelism, continuously adjust the memory configuration, and combine the WebUI of TM and JM to determine whether the memory usage needs to be adjusted. 1. Overview The first step in Flink performance tuning is to allocate appropriate resources to tasks. Within a […]