You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@flink.apache.org by tr...@apache.org on 2019/08/06 05:45:07 UTC
[flink] 01/02: [hotfix][runtime] Fix checkstyles in SlotManagerImpl
class.
This is an automated email from the ASF dual-hosted git repository.
trohrmann pushed a commit to branch release-1.9
in repository https://gitbox.apache.org/repos/asf/flink.git
commit c6dd59b995e144380ddee43ffd225b563363f565
Author: Xintong Song <to...@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);