diff --git a/hadoop-mapreduce-project/CHANGES.txt b/hadoop-mapreduce-project/CHANGES.txt index 0782160d39c..de77619d06a 100644 --- a/hadoop-mapreduce-project/CHANGES.txt +++ b/hadoop-mapreduce-project/CHANGES.txt @@ -82,6 +82,9 @@ Release 0.23.1 - Unreleased MAPREDUCE-3341. Enhance logging of initalized queue limit values. (Anupam Seth via mahadev) + MAPREDUCE-3243. Invalid tracking URL for streaming jobs (Jonathan Eagles + via mahadev) + OPTIMIZATIONS BUG FIXES 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 b68e73e34bb..2da171aecf6 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 @@ -984,19 +984,6 @@ public class StreamJob implements Tool { return jobConf_.get(JTConfig.JT_IPC_ADDRESS); } - protected void jobInfo() { - if (isLocalHadoop()) { - LOG.info("Job running in-process (local Hadoop)"); - } else { - String hp = getJobTrackerHostPort(); - LOG.info("To kill this job, run:"); - LOG.info(getHadoopClientHome() + "/bin/hadoop job -D" + JTConfig.JT_IPC_ADDRESS + "=" + hp + " -kill " - + jobId_); - //LOG.info("Job file: " + running_.getJobFile()); - LOG.info("Tracking URL: " + StreamUtil.qualifyHost(running_.getTrackingURL())); - } - } - // Based on JobClient public int submitAndMonitorJob() throws IOException { @@ -1012,7 +999,6 @@ public class StreamJob implements Tool { try { running_ = jc_.submitJob(jobConf_); jobId_ = running_.getID(); - jobInfo(); if (background_) { LOG.info("Job is running in background."); } else if (!jc_.monitorAndPrintJob(jobConf_, running_)) {