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

MAPREDUCE-3346. [Rumen] LoggedTaskAttempt#getHostName() returns null. (amarrk) 

git-svn-id: https://svn.apache.org/repos/asf/hadoop/common/branches/branch-0.23@1199106 13f79535-47bb-0310-9956-ffa450edef68
This commit is contained in:
Amar Kamat 2011-11-08 04:48:57 +00:00
parent c935780424
commit fcf44394a0
2 changed files with 21 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

2
hadoop-mapreduce-project/CHANGES.txt
View File

@ -15,6 +15,8 @@ Release 0.23.1 - Unreleased
OPTIMIZATIONS OPTIMIZATIONS
BUG FIXES BUG FIXES
MAPREDUCE-3346 [Rumen] LoggedTaskAttempt#getHostName() returns null.
(amarrk)
MAPREDUCE-3221. Reenabled the previously ignored test in TestSubmitJob MAPREDUCE-3221. Reenabled the previously ignored test in TestSubmitJob
and fixed bugs in it. (Devaraj K via vinodkv) and fixed bugs in it. (Devaraj K via vinodkv)

22
hadoop-mapreduce-project/src/tools/org/apache/hadoop/tools/rumen/LoggedTaskAttempt.java
View File

@ -328,11 +328,27 @@ public class LoggedTaskAttempt implements DeepCompare {
return hostName; return hostName;
} }
void setHostName(String hostName) {
this.hostName = hostName;
}
// hostName is saved in the format rackName/NodeName // hostName is saved in the format rackName/NodeName
void setHostName(String hostName, String rackName) { void setHostName(String hostName, String rackName) {
this.hostName = hostName == null || rackName == null ? null if (hostName == null || hostName.length() == 0) {
: rackName.intern() + "/" + hostName.intern(); throw new RuntimeException("Invalid entry! Missing hostname");
} else if (rackName == null || rackName.length() == 0) {
setHostName(hostName);
} else {
// make sure that the rackname is prefixed with a '/'
if (!rackName.startsWith("/")) {
rackName = "/" + rackName;
}
// make sure that the hostname is prefixed with a '/'
if (!hostName.startsWith("/")) {
hostName = "/" + hostName;
}
setHostName(rackName.intern() + hostName.intern());
}
} }
public long getHdfsBytesRead() { public long getHdfsBytesRead() {