hadoop-common-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From ha...@apache.org
Subject svn commit: r1391089 - in /hadoop/common/branches/branch-1: CHANGES.txt src/mapred/org/apache/hadoop/mapred/ReduceTask.java
Date Thu, 27 Sep 2012 16:33:51 GMT
Author: harsh
Date: Thu Sep 27 16:33:51 2012
New Revision: 1391089

URL: http://svn.apache.org/viewvc?rev=1391089&view=rev
Log:
MAPREDUCE-4464. Reduce tasks failing with NullPointerException in ConcurrentHashMap.get().
Contributed by Clint Heath. (harsh)

Modified:
    hadoop/common/branches/branch-1/CHANGES.txt
    hadoop/common/branches/branch-1/src/mapred/org/apache/hadoop/mapred/ReduceTask.java

Modified: hadoop/common/branches/branch-1/CHANGES.txt
URL: http://svn.apache.org/viewvc/hadoop/common/branches/branch-1/CHANGES.txt?rev=1391089&r1=1391088&r2=1391089&view=diff
==============================================================================
--- hadoop/common/branches/branch-1/CHANGES.txt (original)
+++ hadoop/common/branches/branch-1/CHANGES.txt Thu Sep 27 16:33:51 2012
@@ -78,6 +78,9 @@ Release 1.2.0 - unreleased
     MAPREDUCE-2770. Improve hadoop.job.history.location doc in
     mapred-default.xml. (Sandy Ryza via tomwhite)
 
+    MAPREDUCE-4464. Reduce tasks failing with NullPointerException in
+    ConcurrentHashMap.get(). (Clint Heath via harsh)
+
   OPTIMIZATIONS
 
     HDFS-2533. Backport: Remove needless synchronization on some FSDataSet

Modified: hadoop/common/branches/branch-1/src/mapred/org/apache/hadoop/mapred/ReduceTask.java
URL: http://svn.apache.org/viewvc/hadoop/common/branches/branch-1/src/mapred/org/apache/hadoop/mapred/ReduceTask.java?rev=1391089&r1=1391088&r2=1391089&view=diff
==============================================================================
--- hadoop/common/branches/branch-1/src/mapred/org/apache/hadoop/mapred/ReduceTask.java (original)
+++ hadoop/common/branches/branch-1/src/mapred/org/apache/hadoop/mapred/ReduceTask.java Thu
Sep 27 16:33:51 2012
@@ -2916,6 +2916,12 @@ class ReduceTask extends Task {
             {
               URI u = URI.create(event.getTaskTrackerHttp());
               String host = u.getHost();
+              if (host == null) {
+                throw new IOException("Invalid hostname found in tracker" +
+                   " location: '" +
+                   event.getTaskTrackerHttp() +
+                   "'");
+              }
               TaskAttemptID taskId = event.getTaskAttemptId();
               URL mapOutputLocation = new URL(event.getTaskTrackerHttp() + 
                                       "/mapOutput?job=" + taskId.getJobID() +



Mime
View raw message