This is an automated email from the ASF dual-hosted git repository.
chesnay pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/flink.git.
from 85905f8 [FLINK-14834][tests] Disable flaky yarn_kerberos_docker
(default input) test
add acae782 [hotfix][tests] Expose full heartbeat payload
add 60067a8 [FLINK-14503][coordination] Simplify method signature
add 7df7467 [FLINK-14503][coordination] Capture number of partitions
add cf4e0f1 [FLINK-14503][coordination] Add partition report to heartbeat
No new revisions were added by this update.
Summary of changes:
.../partition/TaskExecutorPartitionInfo.java | 29 +++++++-
.../partition/TaskExecutorPartitionTracker.java | 11 ++-
.../TaskExecutorPartitionTrackerImpl.java | 24 +++++--
.../flink/runtime/taskexecutor/TaskExecutor.java | 5 +-
.../taskexecutor/TaskExecutorHeartbeatPayload.java | 11 ++-
.../partition/ClusterPartitionReport.java | 83 ++++++++++++++++++++++
.../TaskExecutorPartitionTrackerImplTest.java | 66 +++++++++++++++++
.../utils/TestingResourceManagerGateway.java | 8 +--
.../TaskExecutorPartitionLifecycleTest.java | 4 +-
.../runtime/taskexecutor/TaskExecutorTest.java | 49 ++++++++++---
10 files changed, 262 insertions(+), 28 deletions(-)
create mode 100644
flink-runtime/src/main/java/org/apache/flink/runtime/taskexecutor/partition/ClusterPartitionReport.java
create mode 100644
flink-runtime/src/test/java/org/apache/flink/runtime/io/network/partition/TaskExecutorPartitionTrackerImplTest.java
