You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@flink.apache.org by tr...@apache.org on 2022/01/20 20:38:01 UTC
[flink] branch master updated (fd7e67f -> dd6069f)
This is an automated email from the ASF dual-hosted git repository.
trohrmann pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/flink.git.
from fd7e67f [FLINK-24697][flink-connectors-kafka] add auto.offset.reset configuration for group-offsets startup mode
add 035b055 [FLINK-25709] Always delete non-deterministic working directories
add dd6069f [FLINK-25709] Add shutdown hook for the TaskManagerRunner
No new revisions were added by this update.
Summary of changes:
.../runtime/entrypoint/ClusterEntrypoint.java | 32 +-
.../runtime/entrypoint/ClusterEntrypointUtils.java | 27 +-
.../runtime/entrypoint/DeterminismEnvelope.java | 70 +++++
.../runtime/taskexecutor/TaskManagerRunner.java | 349 +++++++++++++--------
.../taskexecutor/TaskManagerRunnerTest.java | 12 +-
.../test/recovery/ClusterEntrypointITCase.java | 55 +++-
.../test/recovery/TaskManagerRunnerITCase.java | 57 +++-
7 files changed, 438 insertions(+), 164 deletions(-)
create mode 100644 flink-runtime/src/main/java/org/apache/flink/runtime/entrypoint/DeterminismEnvelope.java