From 29ef7ef0dfb247b05341ac07f15c885ad02e3b4f Mon Sep 17 00:00:00 2001 From: Mahadev Konar Date: Mon, 14 Nov 2011 22:46:15 +0000 Subject: [PATCH] MAPREDUCE-3243. Invalid tracking URL for streaming jobs (Jonathan Eagles via mahadev) - Merging r1201951 from trunk. git-svn-id: https://svn.apache.org/repos/asf/hadoop/common/branches/branch-0.23@1201952 13f79535-47bb-0310-9956-ffa450edef68 --- hadoop-mapreduce-project/CHANGES.txt | 3 +++ .../org/apache/hadoop/streaming/StreamJob.java | 14 -------------- 2 files changed, 3 insertions(+), 14 deletions(-) diff --git a/hadoop-mapreduce-project/CHANGES.txt b/hadoop-mapreduce-project/CHANGES.txt index 723a98526e5..27ad4cf3bd5 100644 --- a/hadoop-mapreduce-project/CHANGES.txt +++ b/hadoop-mapreduce-project/CHANGES.txt @@ -30,6 +30,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_)) {