[flink] branch master updated (3da9540 -> 463fe96)

[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 3da9540  [hotfix][doc] fix typos in RichFunction
     add 3346ab4  [hotfix][runtime] Pipelined partition consumers should not be scheduled in LazyFromSourcesSchedulingStrategy#onExecutionStateChange
     add b025b39  [FLINK-14331][runtime] Introduce TestSchedulingStrategy for flexible scheduler testing
     add a09bfc4  [FLINK-14331][runtime] Cancel the ongoing slot request of a vertex when canceling the vertex
     add 03f58f4  [FLINK-14331][runtime] Reset vertices before asking the scheduling strategy to restart them
     add 42102f2  [FLINK-14331][runtime] Make DefaultScheduler only schedule vertices in CREATED state
     add 463fe96  [hotfix][runtime] DefaultExecutionSlotAllocator checks for duplicated slot allocation

No new revisions were added by this update.

Summary of changes:
 .../scheduler/DefaultExecutionSlotAllocator.java   | 11 ++++
 .../flink/runtime/scheduler/DefaultScheduler.java  | 37 +++++++----
 .../runtime/scheduler/SchedulerOperations.java     |  1 +
 .../LazyFromSourcesSchedulingStrategy.java         |  1 +
 .../DefaultExecutionSlotAllocatorTest.java         | 19 ++++++
 .../runtime/scheduler/DefaultSchedulerTest.java    | 72 +++++++++++++++++++--
 .../strategy/TestSchedulingStrategy.java}          | 74 ++++++++++++----------
 7 files changed, 164 insertions(+), 51 deletions(-)
 copy flink-runtime/src/{main/java/org/apache/flink/runtime/scheduler/strategy/EagerSchedulingStrategy.java => test/java/org/apache/flink/runtime/scheduler/strategy/TestSchedulingStrategy.java} (58%)