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 03c125c [FLINK-14745] Wire the configuration to the
ClientUtils.executeProgram
add 472772b [FLINK-14477][coordination] Move shuffle service access into
TEPartitionTracker
add f892ccb [FLINK-14477][coordination] Implement promotion logic on
TaskExecutor
No new revisions were added by this update.
Summary of changes:
.../partition/TaskExecutorPartitionInfo.java | 21 +++++++
.../partition/TaskExecutorPartitionTracker.java | 22 +++++++
.../TaskExecutorPartitionTrackerImpl.java | 56 ++++++++++++++++++
.../flink/runtime/taskexecutor/TaskExecutor.java | 14 ++---
.../runtime/taskexecutor/TaskManagerRunner.java | 2 +-
.../TaskExecutorPartitionLifecycleTest.java | 68 +++++++++++++++++++---
.../runtime/taskexecutor/TaskExecutorTest.java | 4 +-
.../TaskSubmissionTestEnvironment.java | 2 +-
8 files changed, 170 insertions(+), 19 deletions(-)
