This is an automated email from the ASF dual-hosted git repository.
mapohl pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/flink.git.
from c92cda9 [FLINK-25940][python] Fix the unstable test
test_keyed_process_function_with_state in PyFlink
add 1891870 [hotfix] Makes TestingDispatcher using the set JobResultStore
for recovered dirty job results if none is set
add 8b02480 [hotfix] Introduces timeout variables in
CheckpointResourcesCleanupRunnerTest
add f3ac014 [hotfix] Introduces builder factory method for single-job
JobManaagerRunnerRegistry
add 17c8956 [FLINK-25974] Moves CheckpointsCleaner into
CheckpointResourcesCleanupRunner
add e8a91fd [FLINK-25974] Removes cleanup future cancellation
No new revisions were added by this update.
Summary of changes:
...on.java => JobCancellationFailedException.java} | 15 +-
.../cleanup/CheckpointResourcesCleanupRunner.java | 51 +++---
.../CheckpointResourcesCleanupRunnerFactory.java | 2 -
.../JobMasterServiceLeadershipRunner.java | 3 +-
.../dispatcher/DispatcherCleanupITCase.java | 63 +++++++
.../flink/runtime/dispatcher/DispatcherTest.java | 2 +-
.../runtime/dispatcher/TestingDispatcher.java | 8 +-
.../TestingJobManagerRunnerRegistry.java | 74 ++++++++
.../CheckpointResourcesCleanupRunnerTest.java | 194 +++++++++++++--------
9 files changed, 297 insertions(+), 115 deletions(-)
copy
flink-runtime/src/main/java/org/apache/flink/runtime/dispatcher/{DispatcherException.java
=> JobCancellationFailedException.java} (71%)
