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

Posted to commits@flink.apache.org by ro...@apache.org on 2021/05/10 12:14:28 UTC

[flink] branch release-1.12 updated (daaa01d -> 4fd1344)

This is an automated email from the ASF dual-hosted git repository.

roman pushed a change to branch release-1.12
in repository https://gitbox.apache.org/repos/asf/flink.git.


    from daaa01d  [FLINK-22597] Make JobMaster restartable
     add 4fd1344  [FLINK-21181][runtime] Wait for Invokable cancellation before releasing network resources

No new revisions were added by this update.

Summary of changes:
 .../program/PerJobMiniClusterFactoryTest.java      |   7 +-
 .../runtime/webmonitor/WebFrontendITCase.java      |  15 ++-
 .../iterative/task/AbstractIterativeTask.java      |  12 +-
 .../runtime/iterative/task/IterationHeadTask.java  |   1 +
 .../iterative/task/IterationIntermediateTask.java  |  61 +++++-----
 .../task/IterationSynchronizationSinkTask.java     |   9 ++
 .../runtime/iterative/task/IterationTailTask.java  |  81 +++++++-------
 .../flink/runtime/iterative/task/Terminable.java   |   2 +
 .../runtime/jobgraph/tasks/AbstractInvokable.java  |   6 +-
 .../apache/flink/runtime/operators/BatchTask.java  |   7 +-
 .../flink/runtime/operators/DataSinkTask.java      |   9 +-
 .../flink/runtime/operators/DataSourceTask.java    |   8 +-
 .../org/apache/flink/runtime/taskmanager/Task.java |  31 ++++--
 .../jobmaster/TestingAbstractInvokables.java       |   4 +-
 .../CoordinatorEventsExactlyOnceITCase.java        |   3 +-
 .../TaskExecutorOperatorEventHandlingTest.java     |   4 +-
 .../apache/flink/runtime/taskmanager/TaskTest.java |  18 ++-
 .../runtime/testutils/CancelableInvokable.java     |  21 +++-
 .../apache/flink/runtime/jobmanager/Tasks.scala    |   8 +-
 .../flink/streaming/runtime/tasks/StreamTask.java  |  10 +-
 .../streaming/runtime/tasks/StreamTaskTest.java    | 123 +++++++++++++++++++++
 21 files changed, 339 insertions(+), 101 deletions(-)