You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@flink.apache.org by tr...@apache.org on 2022/01/28 08:25:10 UTC
[flink] branch master updated (b2011e5 -> 77ec805)
This is an automated email from the ASF dual-hosted git repository.
trohrmann pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/flink.git.
from b2011e5 [FLINK-25861][avro] Move states of AbstractAvroBulkFormat into its reader
add 77ec805 [FLINK-25849] Add TaskManager session id to JobMaster.registerTaskManager
No new revisions were added by this update.
Summary of changes:
.../org/apache/flink/testutils/TestingUtils.java | 6 +
.../apache/flink/runtime/jobmaster/JobMaster.java | 156 ++++++++++++---------
.../flink/runtime/jobmaster/JobMasterGateway.java | 8 +-
.../runtime/jobmaster/TaskManagerRegistration.java | 58 ++++++++
.../TaskManagerRegistrationInformation.java | 64 +++++++++
.../taskexecutor/DefaultJobLeaderService.java | 30 ++--
.../flink/runtime/dispatcher/JobMasterTester.java | 9 +-
...asterExecutionDeploymentReconciliationTest.java | 7 +-
.../jobmaster/JobMasterPartitionReleaseTest.java | 7 +-
.../flink/runtime/jobmaster/JobMasterTest.java | 125 +++++++++++++++--
.../runtime/jobmaster/JobMasterTestUtils.java | 7 +-
.../jobmaster/utils/TestingJobMasterGateway.java | 18 +--
.../utils/TestingJobMasterGatewayBuilder.java | 14 +-
.../taskexecutor/DefaultJobLeaderServiceTest.java | 2 +-
...cutorExecutionDeploymentReconciliationTest.java | 2 +-
.../TaskExecutorPartitionLifecycleTest.java | 2 +-
.../runtime/taskexecutor/TaskExecutorTest.java | 8 +-
17 files changed, 391 insertions(+), 132 deletions(-)
create mode 100644 flink-runtime/src/main/java/org/apache/flink/runtime/jobmaster/TaskManagerRegistration.java
create mode 100644 flink-runtime/src/main/java/org/apache/flink/runtime/jobmaster/TaskManagerRegistrationInformation.java