[flink] branch master updated (a9b1266 -> 738cda3)

[ga...@apache.org]

This is an automated email from the ASF dual-hosted git repository.

gary pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/flink.git.


    from a9b1266  [FLINK-14472][runtime] Implement back-pressure monitor with non-blocking outputs
     add 60f7aa0  [FLINK-14708][runtime] Introduce RestartAllStrategy for NG scheduler
     add 56c4664  [FLINK-14131][runtime] Introduce FailoverStrategyFactoryLoader to load NG failover strategy factories
     add 6abc6d9  [FLINK-14131][runtime] DefaultSchedulerFactory uses FailoverStrategyFactoryLoader to load failover strategy factory
     add 738cda3  [FLINK-14682][tests] Enable AbstractTaskManagerProcessFailureRecoveryTest to pass with new DefaultScheduler

No new revisions were added by this update.

Summary of changes:
 .../flip1/FailoverStrategyFactoryLoader.java       | 69 +++++++++++++++++++++
 ...iloverStrategy.java => RestartAllStrategy.java} | 50 ++++++++-------
 .../flink/runtime/scheduler/DefaultScheduler.java  |  7 ++-
 .../runtime/scheduler/DefaultSchedulerFactory.java |  4 +-
 .../flip1/FailoverStrategyFactoryLoaderTest.java   | 72 ++++++++++++++++++++++
 .../failover/flip1/RestartAllStrategyTest.java     | 55 +++++++++++++++++
 ...tractTaskManagerProcessFailureRecoveryTest.java |  1 +
 7 files changed, 234 insertions(+), 24 deletions(-)
 create mode 100644 flink-runtime/src/main/java/org/apache/flink/runtime/executiongraph/failover/flip1/FailoverStrategyFactoryLoader.java
 copy flink-runtime/src/main/java/org/apache/flink/runtime/executiongraph/failover/flip1/{FailoverStrategy.java => RestartAllStrategy.java} (51%)
 create mode 100644 flink-runtime/src/test/java/org/apache/flink/runtime/executiongraph/failover/flip1/FailoverStrategyFactoryLoaderTest.java
 create mode 100644 flink-runtime/src/test/java/org/apache/flink/runtime/executiongraph/failover/flip1/RestartAllStrategyTest.java