Skip to content

Commit 358e928

Browse files
author
Giovanni Matteo Fumarola
committed
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.
1 parent 312d4d4 commit 358e928

File tree

2 files changed

+18
-0
lines changed

2 files changed

+18
-0
lines changed

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

Lines changed: 9 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -237,6 +237,15 @@ public RMContext getRMContext() {
237237
public Resource getPhysicalResource() {
238238
return null;
239239
}
240+
241+
@Override
242+
public boolean isUpdatedCapability() {
243+
return false;
244+
}
245+
246+
@Override
247+
public void resetUpdatedCapability() {
248+
}
240249
}
241250

242251
public static RMNode newNodeInfo(String rackName, String hostName,

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

Lines changed: 9 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -222,4 +222,13 @@ public RMContext getRMContext() {
222222
public Resource getPhysicalResource() {
223223
return null;
224224
}
225+
226+
@Override
227+
public boolean isUpdatedCapability() {
228+
return false;
229+
}
230+
231+
@Override
232+
public void resetUpdatedCapability() {
233+
}
225234
}

0 commit comments

Comments
 (0)