diff --git a/hadoop-mapreduce-project/CHANGES.txt b/hadoop-mapreduce-project/CHANGES.txt index 781e5bef0a..fc2acf7b6b 100644 --- a/hadoop-mapreduce-project/CHANGES.txt +++ b/hadoop-mapreduce-project/CHANGES.txt @@ -1786,6 +1786,9 @@ Release 0.23.0 - Unreleased MAPREDUCE-3250. When AM restarts, client keeps reconnecting to the new AM and prints a lots of logs. (vinodkv via mahadev) + MAPREDUCE-3254. Fixed streaming to set the job.jar by using the right + JobConf ctor. (acmurthy) + Release 0.22.0 - Unreleased INCOMPATIBLE CHANGES diff --git a/hadoop-mapreduce-project/src/contrib/streaming/src/java/org/apache/hadoop/streaming/StreamJob.java b/hadoop-mapreduce-project/src/contrib/streaming/src/java/org/apache/hadoop/streaming/StreamJob.java index a019be7f34..b68e73e34b 100644 --- a/hadoop-mapreduce-project/src/contrib/streaming/src/java/org/apache/hadoop/streaming/StreamJob.java +++ b/hadoop-mapreduce-project/src/contrib/streaming/src/java/org/apache/hadoop/streaming/StreamJob.java @@ -718,7 +718,7 @@ protected void setJobConf() throws IOException { } // general MapRed job properties - jobConf_ = new JobConf(config_); + jobConf_ = new JobConf(config_, StreamJob.class); // All streaming jobs get the task timeout value // from the configuration settings.