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

Posted to commits@flink.apache.org by yu...@apache.org on 2021/09/17 02:15:59 UTC

[flink] branch master updated (164a59a -> 3b6b522)

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

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


    from 164a59a  [FLINK-23180] Do not initialize checkpoint base locations when checkpointing is disabled
     add 3b6b522  [FLINK-11250][runtime] Added method init for RecordWriter for initialization resources(OutputFlusher) outside of constructor (#17187)

No new revisions were added by this update.

Summary of changes:
 .../org/apache/flink/runtime/taskmanager/Task.java |  24 ++---
 .../apache/flink/runtime/taskmanager/TaskTest.java |  20 ++++
 .../runtime/tasks/StreamConfigChainer.java         |  45 ++++----
 .../streaming/runtime/tasks/StreamTaskTest.java    | 120 ++++++++++++++-------
 4 files changed, 136 insertions(+), 73 deletions(-)