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() +
