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:48:21 UTC

svn commit: r1546204 - in /pig/trunk: CHANGES.txt src/org/apache/pig/backend/hadoop/executionengine/mapReduceLayer/MapReduceLauncher.java

Author: aniket486
Date: Wed Nov 27 21:48:20 2013
New Revision: 1546204

URL: http://svn.apache.org/r1546204
Log:
PIG-3576: NPE due to PIG-3549 when job never gets submitted (lbendig via cheolsoo)

Modified:
    pig/trunk/CHANGES.txt
    pig/trunk/src/org/apache/pig/backend/hadoop/executionengine/mapReduceLayer/MapReduceLauncher.java

Modified: pig/trunk/CHANGES.txt
URL: http://svn.apache.org/viewvc/pig/trunk/CHANGES.txt?rev=1546204&r1=1546203&r2=1546204&view=diff
==============================================================================
--- pig/trunk/CHANGES.txt (original)
+++ pig/trunk/CHANGES.txt Wed Nov 27 21:48:20 2013
@@ -62,8 +62,6 @@ PIG-3285: Jobs using HBaseStorage fail t
 
 PIG-3582: Document SUM, MIN, MAX, and AVG functions for BigInteger and BigDecimal (harichinnan via cheolsoo)
 
-PIG-3576: NPE due to PIG-3549 when job never gets submitted (lbendig via cheolsoo)
-
 PIG-3525: PigStats.get() and ScriptState.get() shouldn't return MR-specific objects (cheolsoo)
 
 PIG-3568: Define the semantics of POStatus.STATUS_NULL (mwagner via cheolsoo)
@@ -121,6 +119,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/trunk/src/org/apache/pig/backend/hadoop/executionengine/mapReduceLayer/MapReduceLauncher.java
URL: http://svn.apache.org/viewvc/pig/trunk/src/org/apache/pig/backend/hadoop/executionengine/mapReduceLayer/MapReduceLauncher.java?rev=1546204&r1=1546203&r2=1546204&view=diff
==============================================================================
--- pig/trunk/src/org/apache/pig/backend/hadoop/executionengine/mapReduceLayer/MapReduceLauncher.java (original)
+++ pig/trunk/src/org/apache/pig/backend/hadoop/executionengine/mapReduceLayer/MapReduceLauncher.java Wed Nov 27 21:48:20 2013
@@ -102,7 +102,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) {
@@ -536,7 +536,7 @@ public class MapReduceLauncher extends L
 
             for (int i=0; i<jc.getFailedJobs().size(); i++) {
                 Job j = jc.getFailedJobs().get(i);
-                msg.append("JobID: " + String.valueOf(j.getAssignedJobID()) + " Reason: " + j.getMessage());
+                msg.append("JobID: " + j.getAssignedJobID() + " Reason: " + j.getMessage());
                 if (i!=jc.getFailedJobs().size()-1) {
                     msg.append("\n");
                 }