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 2019/09/02 20:11:26 UTC

[flink] branch master updated (a054799 -> 2bd7999)

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 a054799  [FLINK-13616][Tests] Update BucketingSinkMigrationTest to restore from 1.9 savepoint
     add c0454ef  [Flink-12164][runtime] Introduce factory pattern for HeartbeatMonitor
     add 30f73c1  [Flink-12164][tests] Enrich TestingHeartbeatServices by supporting manually triggering timeout
     add 0e75425  [Flink-12164][tests] Harden JobMasterTest#testJobFailureWhenTaskExecutorHeartbeatTimeout
     add 2bd7999  [hotfix][tests] Fix code style problem of JobMasterTest

No new revisions were added by this update.

Summary of changes:
 .../runtime/heartbeat/HeartbeatManagerImpl.java    | 165 +++++----------------
 .../heartbeat/HeartbeatManagerSenderImpl.java      |  23 ++-
 .../flink/runtime/heartbeat/HeartbeatMonitor.java  |  87 +++++++++++
 .../runtime/heartbeat/HeartbeatMonitorImpl.java    | 160 ++++++++++++++++++++
 .../heartbeat/TestingHeartbeatServices.java        | 165 ++++++++++++++++++++-
 .../flink/runtime/jobmaster/JobMasterTest.java     |  22 +--
 6 files changed, 478 insertions(+), 144 deletions(-)
 create mode 100644 flink-runtime/src/main/java/org/apache/flink/runtime/heartbeat/HeartbeatMonitor.java
 create mode 100644 flink-runtime/src/main/java/org/apache/flink/runtime/heartbeat/HeartbeatMonitorImpl.java