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 2021/08/10 21:25:18 UTC

[flink] branch master updated (ffc9637 -> bdd68e4)

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 ffc9637  [FLINK-23701][docs] Fix Error translation in "Builtin Watermark Generators" page (#16767)
     add bdd68e4  [FLINK-23408] Waiting for final checkpoint completed before finishing a task

No new revisions were added by this update.

Summary of changes:
 .../flink/streaming/runtime/tasks/StreamTask.java  |  30 +-
 ...tStreamTaskChainedSourcesCheckpointingTest.java |   7 +
 .../runtime/tasks/MultipleInputStreamTaskTest.java |   7 +
 .../tasks/StreamTaskFinalCheckpointsTest.java      | 589 ++++++++++++++++-----
 .../util/CompletingCheckpointResponder.java        | 100 ++++
 5 files changed, 587 insertions(+), 146 deletions(-)
 create mode 100644 flink-streaming-java/src/test/java/org/apache/flink/streaming/util/CompletingCheckpointResponder.java