You are viewing a plain text version of this content. The canonical link for it is here.

Posted to commits@flink.apache.org by rm...@apache.org on 2021/02/16 06:25:35 UTC

[flink] branch master updated (fa401b2 -> 577f08c)

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 fa401b2  [FLINK-21365][runtime] Document and make the contract of FutureUtils.ResultConjunctFuture more explicit
     add 2179a23  [FLINK-21259] Add Failing state for DeclarativeScheduler
     add 577f08c  [FLINK-21259] Add tests for Failing state

No new revisions were added by this update.

Summary of changes:
 .../declarative/{Restarting.java => Failing.java}  |  54 ++-----
 .../scheduler/declarative/CancelingTest.java       |  85 ----------
 .../runtime/scheduler/declarative/FailingTest.java | 176 +++++++++++++++++++++
 .../scheduler/declarative/MockExecutionGraph.java  | 123 ++++++++++++++
 4 files changed, 315 insertions(+), 123 deletions(-)
 copy flink-runtime/src/main/java/org/apache/flink/runtime/scheduler/declarative/{Restarting.java => Failing.java} (63%)
 create mode 100644 flink-runtime/src/test/java/org/apache/flink/runtime/scheduler/declarative/FailingTest.java
 create mode 100644 flink-runtime/src/test/java/org/apache/flink/runtime/scheduler/declarative/MockExecutionGraph.java