[hotfix][runtime] Narrow down the access scope of DefaultExecutionSlo…

…tAllocator
shuttie · Jun 16, 2020 · a10f1a4 · a10f1a4
1 parent d75f186
commit a10f1a4
Show file tree

Hide file tree

Showing 2 changed files with 4 additions and 4 deletions.
diff --git a/...ntime/src/main/java/org/apache/flink/runtime/scheduler/DefaultExecutionSlotAllocator.java b/...ntime/src/main/java/org/apache/flink/runtime/scheduler/DefaultExecutionSlotAllocator.java
@@ -43,13 +43,13 @@
  * 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/...rc/main/java/org/apache/flink/runtime/scheduler/DefaultExecutionSlotAllocatorFactory.java b/...rc/main/java/org/apache/flink/runtime/scheduler/DefaultExecutionSlotAllocatorFactory.java
@@ -26,11 +26,11 @@
 /**
  * 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);
 	}