You are viewing a plain text version of this content. The canonical link for it is here.

Posted to commits@flink.apache.org by tr...@apache.org on 2021/11/02 14:27:01 UTC

[flink] branch master updated (365f1b3 -> aae7c59)

This is an automated email from the ASF dual-hosted git repository.

trohrmann pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/flink.git.


    from 365f1b3  [hotfix] Refactor the registerJobManager to registerJobMaster
     add aae7c59  [FLINK-24167][Runtime]Add default HeartbeatReceiver and HeartbeatSender to simplify the usage of HeartbeatTarget

No new revisions were added by this update.

Summary of changes:
 .../flink/runtime/heartbeat/HeartbeatReceiver.java | 25 +++++++++--------
 .../flink/runtime/heartbeat/HeartbeatSender.java   | 25 +++++++++--------
 .../apache/flink/runtime/jobmaster/JobMaster.java  | 31 ++++++---------------
 .../runtime/resourcemanager/ResourceManager.java   | 27 +++++-------------
 .../flink/runtime/taskexecutor/TaskExecutor.java   | 32 ++++++----------------
 5 files changed, 51 insertions(+), 89 deletions(-)
 copy flink-core/src/test/java/org/apache/flink/util/concurrent/TestingUncaughtExceptionHandler.java => flink-runtime/src/main/java/org/apache/flink/runtime/heartbeat/HeartbeatReceiver.java (56%)
 copy flink-core/src/test/java/org/apache/flink/util/concurrent/TestingUncaughtExceptionHandler.java => flink-runtime/src/main/java/org/apache/flink/runtime/heartbeat/HeartbeatSender.java (56%)