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 d67c4d9 [FLINK-21382][docs] Update documentation for standalone Flink
on Kubernetes with standby JobManagers
add 55a1d1b [FLINK-21348] Add tests for AdaptiveScheduler's
StateWithExecutionGraph
No new revisions were added by this update.
Summary of changes:
...java => DefaultOperatorCoordinatorHandler.java} | 13 +-
.../scheduler/OperatorCoordinatorHandler.java | 151 +++++----------------
.../flink/runtime/scheduler/SchedulerBase.java | 2 +-
.../scheduler/adaptive/AdaptiveScheduler.java | 3 +-
.../runtime/scheduler/adaptive/CancelingTest.java | 6 +-
.../runtime/scheduler/adaptive/ExecutingTest.java | 33 +----
.../runtime/scheduler/adaptive/FailingTest.java | 6 +-
.../runtime/scheduler/adaptive/RestartingTest.java | 6 +-
.../adaptive/StateWithExecutionGraphTest.java | 104 +++++++++++---
.../scheduler/adaptive/StopWithSavepointTest.java | 6 +-
.../TestingOperatorCoordinatorHandler.java | 66 +++++++++
11 files changed, 210 insertions(+), 186 deletions(-)
copy
flink-runtime/src/main/java/org/apache/flink/runtime/scheduler/{OperatorCoordinatorHandler.java
=> DefaultOperatorCoordinatorHandler.java} (94%)
create mode 100644
flink-runtime/src/test/java/org/apache/flink/runtime/scheduler/adaptive/TestingOperatorCoordinatorHandler.java
