[flink] branch master updated (eb8100f -> 3214bad)

[tr...@apache.org]

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 eb8100f  [FLINK-22017][coordination] Allow BLOCKING result partition to be individually consumable
     add 56e1c26  [hotfix][tests] Extend ManuallyTriggeredScheduledExecutorService to also return cancelled tasks
     add 8259443  [hotfix][tests] Remove Mockito usage from HeartbeatManagerTest
     add 893ef51  [hotfix] Introduce static inner classes for HeartbeatTargets in JobMaster
     add 22de92d  [hotfix] Introduce static inner classes for HeartbeatTargets in ResourceManager
     add ed9f7d3  [hotfix] Add FutureUtils.unsupportedOperationFuture()
     add 286da60  [hotfix] Introduce static inner classes for HeartbeatTargets in TaskExecutor
     add d4a2906  [hotfix] Add TriConsumerWithException interface
     add 3f7ac47  [FLINK-23209] Introduce HeartbeatListener.notifyTargetUnreachable
     add 3214bad  [FLINK-23209] Introduce failed heartbeat rpc threshold before marking target as unreachable

No new revisions were added by this update.

Summary of changes:
 .../generated/cluster_configuration.html           |   6 +
 .../generated/expert_fault_tolerance_section.html  |  10 +-
 .../generated/heartbeat_manager_configuration.html |  10 +-
 .../configuration/HeartbeatManagerOptions.java     |  31 ++-
 .../apache/flink/util/concurrent/FutureUtils.java  |  14 +
 ...xception.java => TriConsumerWithException.java} |  33 +--
 .../flink/runtime/heartbeat/HeartbeatListener.java |   8 +
 .../runtime/heartbeat/HeartbeatManagerImpl.java    |  64 ++++-
 .../heartbeat/HeartbeatManagerSenderImpl.java      |  10 +-
 .../flink/runtime/heartbeat/HeartbeatMonitor.java  |  11 +-
 .../runtime/heartbeat/HeartbeatMonitorImpl.java    |  53 +++-
 .../flink/runtime/heartbeat/HeartbeatServices.java |  25 +-
 .../flink/runtime/heartbeat/HeartbeatTarget.java   |  10 +-
 .../runtime/heartbeat/NoOpHeartbeatManager.java    |  12 +-
 .../apache/flink/runtime/jobmaster/JobMaster.java  | 141 ++++++----
 .../flink/runtime/jobmaster/JobMasterGateway.java  |   6 +-
 .../runtime/resourcemanager/ResourceManager.java   | 134 ++++++---
 .../resourcemanager/ResourceManagerGateway.java    |  10 +-
 .../flink/runtime/taskexecutor/TaskExecutor.java   | 147 ++++++----
 .../runtime/taskexecutor/TaskExecutorGateway.java  |   6 +-
 .../TaskExecutorGatewayDecoratorBase.java          |   8 +-
 .../checkpoint/CheckpointCoordinatorTest.java      |  24 +-
 .../flink/runtime/concurrent/FutureUtilsTest.java  |   5 +-
 .../ManuallyTriggeredScheduledExecutor.java        |  17 +-
 .../runtime/heartbeat/HeartbeatManagerTest.java    | 307 +++++++++++++++++----
 .../heartbeat/TestingHeartbeatListener.java        |  11 +-
 .../heartbeat/TestingHeartbeatListenerBuilder.java |  12 +-
 .../heartbeat/TestingHeartbeatServices.java        |  14 +-
 .../runtime/heartbeat/TestingHeartbeatTarget.java  |  24 +-
 .../heartbeat/TestingHeartbeatTargetBuilder.java   |  24 +-
 .../flink/runtime/jobmaster/JobMasterTest.java     | 184 ++++++++++--
 .../slotpool/TestingSlotPoolServiceBuilder.java    |   6 +
 .../jobmaster/utils/TestingJobMasterGateway.java   |  29 +-
 .../utils/TestingJobMasterGatewayBuilder.java      |  30 +-
 .../runtime/metrics/MetricRegistryImplTest.java    |   2 +-
 .../resourcemanager/ResourceManagerTest.java       | 107 ++++++-
 .../utils/TestingResourceManagerGateway.java       |  39 ++-
 .../scheduler/adaptive/AdaptiveSchedulerTest.java  |   2 +-
 .../taskexecutor/RecordingHeartbeatServices.java   | 113 ++++++++
 ...cutorExecutionDeploymentReconciliationTest.java |   4 +-
 .../runtime/taskexecutor/TaskExecutorTest.java     | 243 ++++++++--------
 .../taskexecutor/TestingTaskExecutorGateway.java   |  22 +-
 .../TestingTaskExecutorGatewayBuilder.java         |  34 +--
 .../ManuallyTriggeredScheduledExecutorService.java |  26 +-
 ...skManagerProcessFailureBatchRecoveryITCase.java |   2 +-
 45 files changed, 1531 insertions(+), 499 deletions(-)
 copy flink-core/src/main/java/org/apache/flink/util/function/{BiConsumerWithException.java => TriConsumerWithException.java} (59%)
 create mode 100644 flink-runtime/src/test/java/org/apache/flink/runtime/taskexecutor/RecordingHeartbeatServices.java