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
