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

Posted to commits@flink.apache.org by pn...@apache.org on 2020/05/19 13:10:05 UTC

[flink] branch master updated (11644c5 -> cbd9ca0)

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

pnowojski pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/flink.git.


    from 11644c5  [hotfix] Disable e2e execution in PRs
     add cbd9ca0  [FLINK-16383][task] Do not relay notifyCheckpointComplete to closed operators.

No new revisions were added by this update.

Summary of changes:
 .../checkpoint/CheckpointFailureManager.java       |  1 +
 .../checkpoint/CheckpointFailureReason.java        |  2 +
 .../streaming/runtime/tasks/OperatorChain.java     |  4 +-
 .../runtime/tasks/StreamOperatorWrapper.java       | 24 +++++-
 .../tasks/SubtaskCheckpointCoordinatorImpl.java    | 44 +++++++----
 .../runtime/tasks/StreamMockEnvironment.java       | 12 ++-
 .../tasks/StreamTaskMailboxTestHarness.java        |  5 ++
 .../tasks/StreamTaskMailboxTestHarnessBuilder.java |  1 +
 .../streaming/runtime/tasks/StreamTaskTest.java    | 86 ++++++++++++++++++++++
 9 files changed, 161 insertions(+), 18 deletions(-)