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(-)
