You are viewing a plain text version of this content. The canonical link for it is here.

Posted to commits@flink.apache.org by ch...@apache.org on 2019/11/14 10:25:00 UTC

[flink] branch master updated (03c125c -> f892ccb)

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(-)