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

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

git-svn-id: https://svn.apache.org/repos/asf/hadoop/common/trunk@1199105 13f79535-47bb-0310-9956-ffa450edef68
This commit is contained in:
Amar Kamat 2011-11-08 04:44:25 +00:00
parent cb7f819b91
commit 6749d1395f
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

@ -29,6 +29,8 @@ Trunk (unreleased changes)
uri with no authority. (John George via jitendra)
BUG FIXES
MAPREDUCE-3346. [Rumen] LoggedTaskAttempt#getHostName() returns null.
(amarrk)
MAPREDUCE-2950. [Gridmix] TestUserResolve fails in trunk.
(Ravi Gummadi via amarrk)

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;
}
void setHostName(String hostName) {
this.hostName = hostName;
}
// hostName is saved in the format rackName/NodeName
void setHostName(String hostName, String rackName) {
this.hostName = hostName == null || rackName == null ? null
: rackName.intern() + "/" + hostName.intern();
if (hostName == null || hostName.length() == 0) {
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() {