Apache
/
hadoop
1
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

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
This commit is contained in:
Mahadev Konar 2011-11-14 22:46:15 +00:00
parent 6aa52c35d3
commit 29ef7ef0df
2 changed files with 3 additions and 14 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

3
hadoop-mapreduce-project/CHANGES.txt
View File

@ -30,6 +30,9 @@ Release 0.23.1 - Unreleased
MAPREDUCE-3341. Enhance logging of initalized queue limit values. MAPREDUCE-3341. Enhance logging of initalized queue limit values.
(Anupam Seth via mahadev) (Anupam Seth via mahadev)
MAPREDUCE-3243. Invalid tracking URL for streaming jobs (Jonathan Eagles
via mahadev)
OPTIMIZATIONS OPTIMIZATIONS
BUG FIXES BUG FIXES

14
hadoop-mapreduce-project/src/contrib/streaming/src/java/org/apache/hadoop/streaming/StreamJob.java
View File

@ -984,19 +984,6 @@ public class StreamJob implements Tool {
return jobConf_.get(JTConfig.JT_IPC_ADDRESS); 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 // Based on JobClient
public int submitAndMonitorJob() throws IOException { public int submitAndMonitorJob() throws IOException {
@ -1012,7 +999,6 @@ public class StreamJob implements Tool {
try { try {
running_ = jc_.submitJob(jobConf_); running_ = jc_.submitJob(jobConf_);
jobId_ = running_.getID(); jobId_ = running_.getID();
jobInfo();
if (background_) { if (background_) {
LOG.info("Job is running in background."); LOG.info("Job is running in background.");
} else if (!jc_.monitorAndPrintJob(jobConf_, running_)) { } else if (!jc_.monitorAndPrintJob(jobConf_, running_)) {