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/08 09:56:45 UTC
[flink] branch master updated (c1affda -> d788c6f)
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 c1affda [hotfix] Fix checkstyle violations in KeyGroupRangeAssignment
add 2df3ccc [FLINK-14530][coordination] Replace PartitionTable with PartitionTracker
add d788c6f [FLINK-15430][coordination] Store IntermediateDatasetID
No new revisions were added by this update.
Summary of changes:
.../java/org/apache/flink/util/CollectionUtil.java | 10 ++++++
.../partition/JobMasterPartitionTrackerImpl.java | 13 ++------
.../partition/TaskExecutorPartitionInfo.java} | 20 +++++++-----
.../partition/TaskExecutorPartitionTracker.java} | 19 +++++++-----
.../TaskExecutorPartitionTrackerImpl.java} | 21 ++++++++-----
.../flink/runtime/taskexecutor/TaskExecutor.java | 36 ++++++++++++----------
.../runtime/taskexecutor/TaskManagerRunner.java | 4 +--
.../TaskExecutorPartitionLifecycleTest.java | 27 +++++++++-------
.../runtime/taskexecutor/TaskExecutorTest.java | 6 ++--
.../TaskSubmissionTestEnvironment.java | 4 +--
.../runtime/taskexecutor/TestingTaskExecutor.java | 7 ++---
11 files changed, 98 insertions(+), 69 deletions(-)
copy flink-runtime/src/main/java/org/apache/flink/runtime/{jobgraph/topology/LogicalVertex.java => io/network/partition/TaskExecutorPartitionInfo.java} (64%)
copy flink-runtime/src/main/java/org/apache/flink/runtime/{jobgraph/topology/LogicalResult.java => io/network/partition/TaskExecutorPartitionTracker.java} (59%)
copy flink-runtime/src/main/java/org/apache/flink/runtime/{jobgraph/topology/LogicalVertex.java => io/network/partition/TaskExecutorPartitionTrackerImpl.java} (51%)