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 fb31e280 [hotfix] Do not use ExecutorService.submit since it can
swallow exceptions
add 6be9668 [FLINK-22431] Add information when and why the
AdaptiveScheduler restarts or fails jobs
add b88b290 [hotfix] Add debug logging to the states of the
AdaptiveScheduler
add df301ed [hotfix] Harden against FLINK-21376 by checking for null
failure cause
No new revisions were added by this update.
Summary of changes:
.../scheduler/adaptive/AdaptiveScheduler.java | 18 +++++++++++++----
.../runtime/scheduler/adaptive/Canceling.java | 6 +++++-
.../runtime/scheduler/adaptive/Executing.java | 23 +++++++++++++---------
.../flink/runtime/scheduler/adaptive/Failing.java | 6 +++++-
.../flink/runtime/scheduler/adaptive/Finished.java | 7 ++++++-
.../runtime/scheduler/adaptive/Restarting.java | 6 +++++-
.../adaptive/StateWithExecutionGraph.java | 4 ++++
.../scheduler/adaptive/StopWithSavepoint.java | 8 +++++++-
.../runtime/scheduler/adaptive/ExecutingTest.java | 5 +++--
.../scheduler/adaptive/StopWithSavepointTest.java | 6 +++---
10 files changed, 66 insertions(+), 23 deletions(-)
