big-data/hadoop
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

YARN-4644. TestRMRestart fails and findbugs issue in YARN-2928 branch (Varun Saxena via Naganarasimha G R)

Browse Source
This commit is contained in:
Naganarasimha 2016-01-28 17:54:15 +05:30 committed by Sangjin Lee
parent 9d40d9d34c
commit 06f0b50a28
2 changed files with 0 additions and 5 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

2
hadoop-yarn-project/hadoop-yarn/hadoop-yarn-server/hadoop-yarn-server-resourcemanager/src/main/java/org/apache/hadoop/yarn/server/resourcemanager/ResourceTrackerService.java
View File

@ -550,8 +550,6 @@ public NodeHeartbeatResponse nodeHeartbeat(NodeHeartbeatRequest request)
} }
// 4. Send status to RMNode, saving the latest response. // 4. Send status to RMNode, saving the latest response.
List<ApplicationId> keepAliveApps =
remoteNodeStatus.getKeepAliveApplications();
RMNodeStatusEvent nodeStatusEvent = RMNodeStatusEvent nodeStatusEvent =
new RMNodeStatusEvent(nodeId, remoteNodeStatus, nodeHeartBeatResponse); new RMNodeStatusEvent(nodeId, remoteNodeStatus, nodeHeartBeatResponse);
if (request.getLogAggregationReportsForApps() != null if (request.getLogAggregationReportsForApps() != null

3
hadoop-yarn-project/hadoop-yarn/hadoop-yarn-server/hadoop-yarn-server-resourcemanager/src/main/java/org/apache/hadoop/yarn/server/resourcemanager/rmapp/RMAppImpl.java
View File

@ -874,9 +874,6 @@ public void recover(RMState state) {
this.firstAttemptIdInStateStore = appState.getFirstAttemptId(); this.firstAttemptIdInStateStore = appState.getFirstAttemptId();
this.nextAttemptId = firstAttemptIdInStateStore; this.nextAttemptId = firstAttemptIdInStateStore;
} }
// send the ATS create Event
sendATSCreateEvent(this, this.startTime);
//TODO recover collector address. //TODO recover collector address.
//this.collectorAddr = appState.getCollectorAddr(); //this.collectorAddr = appState.getCollectorAddr();