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
