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