You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@flink.apache.org by ga...@apache.org on 2019/10/13 16:38:40 UTC
[flink] branch master updated (ddfed72 -> dbe1bfa)

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 ddfed72  [FLINK-14208][python] Support Python UDFs with parameters of constant values
     add aaebe3b  [hotfix][runtime] Make SchedulerBase#getInputsLocationsRetriever() final
     add 390428d  [hotfix][runtime] Make SchedulerBase#getFailoverTopology() final
     add e39a556  [hotfix][runtime] Make SchedulerBase#getSchedulingTopology() final
     add afd05d3  [hotfix][tests] Remove unused methods from FailingExecutionVertexOperationsDecorator
     add dbe1bfa  [FLINK-14291][runtime, tests] Add test coverage to DefaultScheduler

No new revisions were added by this update.

Summary of changes:
 ...a => DefaultExecutionSlotAllocatorFactory.java} |  32 +++--
 .../flink/runtime/scheduler/DefaultScheduler.java  |   5 +-
 .../runtime/scheduler/DefaultSchedulerFactory.java |   3 +-
 .../scheduler/ExecutionSlotAllocatorFactory.java   |  15 +--
 .../flink/runtime/scheduler/SchedulerBase.java     |   6 +-
 .../runtime/scheduler/DefaultSchedulerTest.java    | 101 ++++++++++------
 .../SubmissionTrackingTaskManagerGateway.java      |  94 ---------------
 .../scheduler/TestExecutionSlotAllocator.java      | 129 +++++++++++++++++++++
 .../TestExecutionSlotAllocatorFactory.java}        |  19 ++-
 ...=> TestExecutionVertexOperationsDecorator.java} |  36 +++---
 10 files changed, 248 insertions(+), 192 deletions(-)
 copy flink-runtime/src/main/java/org/apache/flink/runtime/scheduler/{UpdateSchedulerNgOnInternalTaskFailuresListener.java => DefaultExecutionSlotAllocatorFactory.java} (51%)
 copy flink-libraries/flink-gelly-examples/src/main/java/org/apache/flink/graph/drivers/output/OutputBase.java => flink-runtime/src/main/java/org/apache/flink/runtime/scheduler/ExecutionSlotAllocatorFactory.java (76%)
 delete mode 100644 flink-runtime/src/test/java/org/apache/flink/runtime/scheduler/SubmissionTrackingTaskManagerGateway.java
 create mode 100644 flink-runtime/src/test/java/org/apache/flink/runtime/scheduler/TestExecutionSlotAllocator.java
 copy flink-runtime/src/{main/java/org/apache/flink/runtime/scheduler/DefaultExecutionVertexOperations.java => test/java/org/apache/flink/runtime/scheduler/TestExecutionSlotAllocatorFactory.java} (64%)
 rename flink-runtime/src/test/java/org/apache/flink/runtime/scheduler/{FailingExecutionVertexOperationsDecorator.java => TestExecutionVertexOperationsDecorator.java} (67%)