This is an automated email from the ASF dual-hosted git repository.
rmetzger pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/flink.git.
from f3155e6 [FLINK-21768][client]Optimize system.exit() logic of
CliFrontend
add 11550ed [FLINK-21333] Add StopWithSavepoint state to adaptive
scheduler
No new revisions were added by this update.
Summary of changes:
.../program/PerJobMiniClusterFactoryTest.java | 3 -
flink-end-to-end-tests/run-nightly-tests.sh | 64 ++-
.../runtime/checkpoint/CheckpointCoordinator.java | 7 +
.../executiongraph/DefaultExecutionGraph.java | 5 +-
.../flink/runtime/scheduler/SchedulerBase.java | 24 +-
.../scheduler/adaptive/AdaptiveScheduler.java | 66 ++-
.../adaptive/CheckpointSchedulingProvider.java | 64 +++
.../runtime/scheduler/adaptive/Executing.java | 53 +-
.../adaptive/StateWithExecutionGraph.java | 5 -
.../{Executing.java => StopWithSavepoint.java} | 312 ++++++------
.../StopWithSavepointTerminationHandler.java | 4 +-
.../StopWithSavepointTerminationManager.java | 31 ++
.../flink/runtime/taskexecutor/TaskExecutor.java | 5 +-
.../runtime/scheduler/adaptive/ExecutingTest.java | 117 ++++-
.../runtime/scheduler/adaptive/FailingTest.java | 9 +-
.../MockStateWithExecutionGraphContext.java | 6 +-
.../runtime/scheduler/adaptive/RestartingTest.java | 9 +-
.../adaptive/StateTrackingMockExecutionGraph.java | 20 +-
.../scheduler/adaptive/StopWithSavepointTest.java | 536 +++++++++++++++++++++
.../runtime/testutils/MiniClusterResource.java | 84 ++--
.../flink/test/checkpointing/SavepointITCase.java | 120 +++--
.../UnalignedCheckpointCompatibilityITCase.java | 3 -
.../test/scheduling/AdaptiveSchedulerITCase.java | 229 ++++++++-
.../test/streaming/runtime/TimestampITCase.java | 10 +-
24 files changed, 1425 insertions(+), 361 deletions(-)
create mode 100644
flink-runtime/src/main/java/org/apache/flink/runtime/scheduler/adaptive/CheckpointSchedulingProvider.java
copy
flink-runtime/src/main/java/org/apache/flink/runtime/scheduler/adaptive/{Executing.java
=> StopWithSavepoint.java} (52%)
create mode 100644
flink-runtime/src/test/java/org/apache/flink/runtime/scheduler/adaptive/StopWithSavepointTest.java
