Apache
/
hadoop
1
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

YARN-8977. Remove unnecessary type casting when calling AbstractYarnScheduler#getSchedulerNode. Contributed by Wanqiang Ji.

This commit is contained in:
Weiwei Yang 2018-11-07 22:27:57 +08:00
parent 0b6625a973
commit c96cbe8659
3 changed files with 5 additions and 7 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

6
hadoop-yarn-project/hadoop-yarn/hadoop-yarn-server/hadoop-yarn-server-resourcemanager/src/main/java/org/apache/hadoop/yarn/server/resourcemanager/scheduler/capacity/CapacityScheduler.java
View File

@ -2192,8 +2192,8 @@ public class CapacityScheduler extends
super.completedContainer(killableContainer, SchedulerUtils super.completedContainer(killableContainer, SchedulerUtils
.createPreemptedContainerStatus(killableContainer.getContainerId(), .createPreemptedContainerStatus(killableContainer.getContainerId(),
SchedulerUtils.PREEMPTED_CONTAINER), RMContainerEventType.KILL); SchedulerUtils.PREEMPTED_CONTAINER), RMContainerEventType.KILL);
} else{ } else {
FiCaSchedulerNode node = (FiCaSchedulerNode) getSchedulerNode( FiCaSchedulerNode node = getSchedulerNode(
killableContainer.getAllocatedNode()); killableContainer.getAllocatedNode());
FiCaSchedulerApp application = getCurrentAttemptForContainer( FiCaSchedulerApp application = getCurrentAttemptForContainer(
@ -2225,7 +2225,7 @@ public class CapacityScheduler extends
+ nonKillableContainer.toString()); + nonKillableContainer.toString());
} }
FiCaSchedulerNode node = (FiCaSchedulerNode) getSchedulerNode( FiCaSchedulerNode node = getSchedulerNode(
nonKillableContainer.getAllocatedNode()); nonKillableContainer.getAllocatedNode());
FiCaSchedulerApp application = getCurrentAttemptForContainer( FiCaSchedulerApp application = getCurrentAttemptForContainer(

3
hadoop-yarn-project/hadoop-yarn/hadoop-yarn-server/hadoop-yarn-server-resourcemanager/src/test/java/org/apache/hadoop/yarn/server/resourcemanager/scheduler/fair/TestContinuousScheduling.java
View File

@ -376,8 +376,7 @@ public class TestContinuousScheduling extends FairSchedulerTestBase {
NodeAddedSchedulerEvent nodeEvent1 = new NodeAddedSchedulerEvent(node1); NodeAddedSchedulerEvent nodeEvent1 = new NodeAddedSchedulerEvent(node1);
scheduler.handle(nodeEvent1); scheduler.handle(nodeEvent1);
FSSchedulerNode node = FSSchedulerNode node = scheduler.getSchedulerNode(node1.getNodeID());
(FSSchedulerNode) scheduler.getSchedulerNode(node1.getNodeID());
// Tick the time and let the fsApp startTime different from initScheduler // Tick the time and let the fsApp startTime different from initScheduler
// time // time
mockClock.tickSec(delayThresholdTimeMs / 1000); mockClock.tickSec(delayThresholdTimeMs / 1000);

3
hadoop-yarn-project/hadoop-yarn/hadoop-yarn-server/hadoop-yarn-server-resourcemanager/src/test/java/org/apache/hadoop/yarn/server/resourcemanager/scheduler/fair/TestFairScheduler.java
View File

@ -4557,8 +4557,7 @@ public class TestFairScheduler extends FairSchedulerTestBase {
NodeAddedSchedulerEvent nodeEvent1 = new NodeAddedSchedulerEvent(node1); NodeAddedSchedulerEvent nodeEvent1 = new NodeAddedSchedulerEvent(node1);
scheduler.handle(nodeEvent1); scheduler.handle(nodeEvent1);
FSSchedulerNode node = (FSSchedulerNode)scheduler.getSchedulerNode( FSSchedulerNode node = scheduler.getSchedulerNode(node1.getNodeID());
node1.getNodeID());
NodeRemovedSchedulerEvent removeNode1 = NodeRemovedSchedulerEvent removeNode1 =
new NodeRemovedSchedulerEvent(node1); new NodeRemovedSchedulerEvent(node1);