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