This is an automated email from the ASF dual-hosted git repository. zhuzh pushed a commit to branch master in repository https://gitbox.apache.org/repos/asf/flink.git
commit a10f1a47ca200bcc1d0b63e068459729854302dc Author: Zhu Zhu <[email protected]> AuthorDate: Thu Jun 11 23:01:49 2020 +0800 [hotfix][runtime] Narrow down the access scope of DefaultExecutionSlotAllocator --- .../apache/flink/runtime/scheduler/DefaultExecutionSlotAllocator.java | 4 ++-- .../flink/runtime/scheduler/DefaultExecutionSlotAllocatorFactory.java | 4 ++-- 2 files changed, 4 insertions(+), 4 deletions(-) diff --git a/flink-runtime/src/main/java/org/apache/flink/runtime/scheduler/DefaultExecutionSlotAllocator.java b/flink-runtime/src/main/java/org/apache/flink/runtime/scheduler/DefaultExecutionSlotAllocator.java index 07da10e..f54aa24 100644 --- a/flink-runtime/src/main/java/org/apache/flink/runtime/scheduler/DefaultExecutionSlotAllocator.java +++ b/flink-runtime/src/main/java/org/apache/flink/runtime/scheduler/DefaultExecutionSlotAllocator.java @@ -43,13 +43,13 @@ import static org.apache.flink.util.Preconditions.checkNotNull; * Default {@link ExecutionSlotAllocator} which will use {@link SlotProvider} to allocate slots and * keep the unfulfilled requests for further cancellation. */ -public class DefaultExecutionSlotAllocator extends AbstractExecutionSlotAllocator { +class DefaultExecutionSlotAllocator extends AbstractExecutionSlotAllocator { private static final Logger LOG = LoggerFactory.getLogger(DefaultExecutionSlotAllocator.class); private final SlotProviderStrategy slotProviderStrategy; - public DefaultExecutionSlotAllocator( + DefaultExecutionSlotAllocator( final SlotProviderStrategy slotProviderStrategy, final PreferredLocationsRetriever preferredLocationsRetriever) { diff --git a/flink-runtime/src/main/java/org/apache/flink/runtime/scheduler/DefaultExecutionSlotAllocatorFactory.java b/flink-runtime/src/main/java/org/apache/flink/runtime/scheduler/DefaultExecutionSlotAllocatorFactory.java index ef8a4e1..4324c3b 100644 --- a/flink-runtime/src/main/java/org/apache/flink/runtime/scheduler/DefaultExecutionSlotAllocatorFactory.java +++ b/flink-runtime/src/main/java/org/apache/flink/runtime/scheduler/DefaultExecutionSlotAllocatorFactory.java @@ -26,11 +26,11 @@ import static org.apache.flink.util.Preconditions.checkNotNull; /** * Factory for {@link DefaultExecutionSlotAllocator}. */ -public class DefaultExecutionSlotAllocatorFactory implements ExecutionSlotAllocatorFactory { +class DefaultExecutionSlotAllocatorFactory implements ExecutionSlotAllocatorFactory { private final SlotProviderStrategy slotProvider; - public DefaultExecutionSlotAllocatorFactory(final SlotProviderStrategy slotProvider) { + DefaultExecutionSlotAllocatorFactory(final SlotProviderStrategy slotProvider) { this.slotProvider = checkNotNull(slotProvider); }
