[ https://issues.apache.org/jira/browse/FLINK-24167?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ]
Aitozi updated FLINK-24167: --------------------------- Description: Currently, {{HeartbeatTarget}} is responsible for the {{receiveHeartbeat}} and {{requestHeartbeat}}. But many components just need one of them and let the not needed interface implements with {{unsupportedOperationFuture}}. This makes the implementation not so clear. Can we split the {{HeartbeatTarget}} to {{HeartbeatReceiver}} and {{HeartbeatSender}}. The {{HeartbeatReceiver}} only care about the logic when receive a heartbeat. The {{HeartbeatSender}} only care about the logic of send heartbeat. was: Currently, {{HeartbeatTarget}} is responsible for the {{receiveHeartbeat}} and {{requestHeartbeat}}. But may component just need one of them and let the not needed one implements with {{unsupportedOperationFuture}}. This makes the implementation not so clear. Can we split the {{HeartbeatTarget}} to {{HeartbeatReceiver}} and {{HeartbeatSender}}. The {{HeartbeatReceiver}} only care about the logic when receive a heartbeat. The {{HeartbeatSender}} only care about the logic of send heartbeat. > Split HeartbeatTarget to HeartbeatReceiver and HeartbeatSender > --------------------------------------------------------------- > > Key: FLINK-24167 > URL: https://issues.apache.org/jira/browse/FLINK-24167 > Project: Flink > Issue Type: Improvement > Components: Runtime / Coordination > Reporter: Aitozi > Priority: Minor > > Currently, {{HeartbeatTarget}} is responsible for the {{receiveHeartbeat}} > and {{requestHeartbeat}}. But many components just need one of them and let > the not needed interface implements with {{unsupportedOperationFuture}}. This > makes the implementation not so clear. Can we split the {{HeartbeatTarget}} > to {{HeartbeatReceiver}} and {{HeartbeatSender}}. > The {{HeartbeatReceiver}} only care about the logic when receive a heartbeat. > The {{HeartbeatSender}} only care about the logic of send heartbeat. -- This message was sent by Atlassian Jira (v8.3.4#803005)