This is an automated email from the ASF dual-hosted git repository. trohrmann pushed a commit to branch master in repository https://gitbox.apache.org/repos/asf/flink.git
commit d6dbf88bd8c68243ba4dcc31ffd6e7d55a34185d Author: Xintong Song <tonysong...@gmail.com> AuthorDate: Fri Aug 2 14:42:40 2019 +0200 [hotfix][runtime] Fix checkstyles in SlotManagerImpl class. --- .../flink/runtime/resourcemanager/slotmanager/SlotManagerImpl.java | 4 +--- 1 file changed, 1 insertion(+), 3 deletions(-) diff --git a/flink-runtime/src/main/java/org/apache/flink/runtime/resourcemanager/slotmanager/SlotManagerImpl.java b/flink-runtime/src/main/java/org/apache/flink/runtime/resourcemanager/slotmanager/SlotManagerImpl.java index 4e4124b..cd894e3 100755 --- a/flink-runtime/src/main/java/org/apache/flink/runtime/resourcemanager/slotmanager/SlotManagerImpl.java +++ b/flink-runtime/src/main/java/org/apache/flink/runtime/resourcemanager/slotmanager/SlotManagerImpl.java @@ -117,7 +117,6 @@ public class SlotManagerImpl implements SlotManager { /** * If true, fail unfulfillable slot requests immediately. Otherwise, allow unfulfillable request to pend. - * * A slot request is considered unfulfillable if it cannot be fulfilled by neither a slot that is already registered * (including allocated ones) nor a pending slot that the {@link ResourceActions} can allocate. * */ @@ -211,8 +210,7 @@ public class SlotManagerImpl implements SlotManager { * @param newResourceActions to use for resource (de-)allocations */ @Override - public void start(ResourceManagerId newResourceManagerId, Executor newMainThreadExecutor, - ResourceActions newResourceActions) { + public void start(ResourceManagerId newResourceManagerId, Executor newMainThreadExecutor, ResourceActions newResourceActions) { LOG.info("Starting the SlotManager."); this.resourceManagerId = Preconditions.checkNotNull(newResourceManagerId);