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%)
