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 9dc7731 [FLINK-16828][prometheus][metrics] Support factories
add d8b4679 [hotfix][coordination] Exit early for empty collection
add 2b11932 [hotfix][tests] Rename variable
add 22a3e8a [FLINK-14792][coordination] Rework partition storage
add 1ce9fcb [FLINK-14792][coordination] Implement TE cluster partition
release
No new revisions were added by this update.
Summary of changes:
.../partition/TaskExecutorPartitionTracker.java | 8 +++
.../TaskExecutorPartitionTrackerImpl.java | 82 +++++++++++++++-------
.../flink/runtime/taskexecutor/TaskExecutor.java | 6 ++
.../runtime/taskexecutor/TaskExecutorGateway.java | 9 +++
.../TaskExecutorPartitionTrackerImplTest.java | 21 ++++++
.../TestingTaskExecutorPartitionTracker.java | 11 +++
.../TaskExecutorPartitionLifecycleTest.java | 46 ++++++++----
.../taskexecutor/TestingTaskExecutorGateway.java | 5 ++
8 files changed, 151 insertions(+), 37 deletions(-)
