Selaa lähdekoodia

YARN-999. In case of long running tasks, reduce node resource should balloon out resource quickly by calling preemption API and suspending running task. Addendum. Contributed by Inigo Goiri.

Giovanni Matteo Fumarola 6 vuotta sitten
vanhempi
commit
358e928622

+ 9 - 0
hadoop-tools/hadoop-sls/src/main/java/org/apache/hadoop/yarn/sls/nodemanager/NodeInfo.java

@@ -237,6 +237,15 @@ public class NodeInfo {
     public Resource getPhysicalResource() {
       return null;
     }
+
+    @Override
+    public boolean isUpdatedCapability() {
+      return false;
+    }
+
+    @Override
+    public void resetUpdatedCapability() {
+    }
   }
 
   public static RMNode newNodeInfo(String rackName, String hostName,

+ 9 - 0
hadoop-tools/hadoop-sls/src/main/java/org/apache/hadoop/yarn/sls/scheduler/RMNodeWrapper.java

@@ -222,4 +222,13 @@ public class RMNodeWrapper implements RMNode {
   public Resource getPhysicalResource() {
     return null;
   }
+
+  @Override
+  public boolean isUpdatedCapability() {
+    return false;
+  }
+
+  @Override
+  public void resetUpdatedCapability() {
+  }
 }