You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@pig.apache.org by an...@apache.org on 2013/10/29 19:25:35 UTC
svn commit: r1536839 - in /pig/branches/branch-0.12: CHANGES.txt
src/org/apache/pig/backend/hadoop/executionengine/mapReduceLayer/MapReduceLauncher.java
Author: aniket486
Date: Tue Oct 29 18:25:35 2013
New Revision: 1536839
URL: http://svn.apache.org/r1536839
Log:
PIG-3549: Print hadoop jobids for failed, killed job (aniket486)
Modified:
pig/branches/branch-0.12/CHANGES.txt
pig/branches/branch-0.12/src/org/apache/pig/backend/hadoop/executionengine/mapReduceLayer/MapReduceLauncher.java
Modified: pig/branches/branch-0.12/CHANGES.txt
URL: http://svn.apache.org/viewvc/pig/branches/branch-0.12/CHANGES.txt?rev=1536839&r1=1536838&r2=1536839&view=diff
==============================================================================
--- pig/branches/branch-0.12/CHANGES.txt (original)
+++ pig/branches/branch-0.12/CHANGES.txt Tue Oct 29 18:25:35 2013
@@ -22,6 +22,8 @@ Release 0.12.1 (unreleased changes)
IMPROVEMENTS
+PIG-3549: Print hadoop jobids for failed, killed job (aniket486)
+
PIG-3047: Check the size of a relation before adding it to distributed cache in Replicated join (aniket486)
PIG-3480: TFile-based tmpfile compression crashes in some cases (dvryaboy via aniket486)
Modified: pig/branches/branch-0.12/src/org/apache/pig/backend/hadoop/executionengine/mapReduceLayer/MapReduceLauncher.java
URL: http://svn.apache.org/viewvc/pig/branches/branch-0.12/src/org/apache/pig/backend/hadoop/executionengine/mapReduceLayer/MapReduceLauncher.java?rev=1536839&r1=1536838&r2=1536839&view=diff
==============================================================================
--- pig/branches/branch-0.12/src/org/apache/pig/backend/hadoop/executionengine/mapReduceLayer/MapReduceLauncher.java (original)
+++ pig/branches/branch-0.12/src/org/apache/pig/backend/hadoop/executionengine/mapReduceLayer/MapReduceLauncher.java Tue Oct 29 18:25:35 2013
@@ -110,7 +110,7 @@ public class MapReduceLauncher extends L
RunningJob runningJob = job.getJobClient().getJob(job.getAssignedJobID());
if (runningJob!=null)
runningJob.killJob();
- log.info("Job " + job.getJobID() + " killed");
+ log.info("Job " + job.getAssignedJobID().toString() + " killed");
}
}
} catch (Exception e) {
@@ -510,7 +510,7 @@ public class MapReduceLauncher extends L
for (int i=0; i<jc.getFailedJobs().size(); i++) {
Job j = jc.getFailedJobs().get(i);
- msg.append(j.getMessage());
+ msg.append("JobID: " + j.getAssignedJobID().toString() + " Reason: " + j.getMessage());
if (i!=jc.getFailedJobs().size()-1) {
msg.append("\n");
}