You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@flink.apache.org by zh...@apache.org on 2020/06/11 01:15:21 UTC
[flink] branch master updated (3dedb85 -> 216f65f)

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

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


    from 3dedb85  [FLINK-18239][e2e] Pin minikube version to v1.8.2
     add e850760  [FLINK-18034][runtime] Introduce PreferredLocationsRetriever
     add 31282fe  [FLINK-18034][runtime] ExecutionSlotAllocator uses PreferredLocationsRetriever to get preferred locations for tasks
     add 8ef1e7d  [FLINK-18034][runtime] Remove unused preferredLocations from ExecutionVertexSchedulingRequirements
     add 216f65f  [hotfix][runtime] Remove ExecutionSlotAllocator#stop() which is never used in production

No new revisions were added by this update.

Summary of changes:
 .../scheduler/DefaultExecutionSlotAllocator.java   |  89 +---------
 .../DefaultExecutionSlotAllocatorFactory.java      |   4 +-
 .../DefaultPreferredLocationsRetriever.java        | 142 +++++++++++++++
 .../flink/runtime/scheduler/DefaultScheduler.java  |   2 +-
 .../runtime/scheduler/ExecutionSlotAllocator.java  |   6 -
 .../scheduler/ExecutionSlotAllocatorFactory.java   |   2 +-
 .../ExecutionVertexSchedulingRequirements.java     |  24 +--
 ...xecutionVertexSchedulingRequirementsMapper.java |  13 +-
 ...iever.java => PreferredLocationsRetriever.java} |  27 ++-
 .../flink/runtime/scheduler/SchedulerBase.java     |  11 +-
 .../runtime/scheduler/StateLocationRetriever.java  |  18 +-
 ...ecutionSlotAllocatorPreferredLocationsTest.java | 116 -------------
 .../DefaultExecutionSlotAllocatorTest.java         |  49 +++---
 .../DefaultPreferredLocationsRetrieverTest.java    | 190 +++++++++++++++++++++
 .../scheduler/TestExecutionSlotAllocator.java      |   5 -
 .../TestExecutionSlotAllocatorFactory.java         |   2 +-
 .../scheduler/TestingStateLocationRetriever.java}  |  27 ++-
 17 files changed, 407 insertions(+), 320 deletions(-)
 create mode 100644 flink-runtime/src/main/java/org/apache/flink/runtime/scheduler/DefaultPreferredLocationsRetriever.java
 copy flink-runtime/src/main/java/org/apache/flink/runtime/scheduler/{InputsLocationsRetriever.java => PreferredLocationsRetriever.java} (57%)
 copy flink-end-to-end-tests/flink-end-to-end-tests-common-kafka/src/main/java/org/apache/flink/tests/util/kafka/KafkaResourceFactory.java => flink-runtime/src/main/java/org/apache/flink/runtime/scheduler/StateLocationRetriever.java (59%)
 delete mode 100644 flink-runtime/src/test/java/org/apache/flink/runtime/scheduler/DefaultExecutionSlotAllocatorPreferredLocationsTest.java
 create mode 100644 flink-runtime/src/test/java/org/apache/flink/runtime/scheduler/DefaultPreferredLocationsRetrieverTest.java
 copy flink-runtime/src/{main/java/org/apache/flink/runtime/scheduler/ExecutionVertexDeploymentOption.java => test/java/org/apache/flink/runtime/scheduler/TestingStateLocationRetriever.java} (57%)