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/11/27 22:50:17 UTC
svn commit: r1546205 - in /pig/branches/branch-0.12: CHANGES.txt
src/org/apache/pig/backend/hadoop/executionengine/mapReduceLayer/MapReduceLauncher.java
Author: aniket486
Date: Wed Nov 27 21:50:16 2013
New Revision: 1546205
URL: http://svn.apache.org/r1546205
Log:
PIG-3576: NPE due to PIG-3549 when job never gets submitted (lbendig via cheolsoo)
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=1546205&r1=1546204&r2=1546205&view=diff
==============================================================================
--- pig/branches/branch-0.12/CHANGES.txt (original)
+++ pig/branches/branch-0.12/CHANGES.txt Wed Nov 27 21:50:16 2013
@@ -32,6 +32,8 @@ PIG-3480: TFile-based tmpfile compressio
BUG FIXES
+PIG-3576: NPE due to PIG-3549 when job never gets submitted (lbendig via cheolsoo)
+
PIG-3567: LogicalPlanPrinter throws OOM for large scripts (aniket486)
PIG-3579: pig.script's deserialized version does not maintain line numbers (jgzhang 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=1546205&r1=1546204&r2=1546205&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 Wed Nov 27 21:50:16 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.getAssignedJobID().toString() + " killed");
+ log.info("Job " + job.getAssignedJobID() + " 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("JobID: " + j.getAssignedJobID().toString() + " Reason: " + j.getMessage());
+ msg.append("JobID: " + j.getAssignedJobID() + " Reason: " + j.getMessage());
if (i!=jc.getFailedJobs().size()-1) {
msg.append("\n");
}