You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@pig.apache.org by ch...@apache.org on 2013/11/18 19:30:28 UTC
svn commit: r1543100 - in /pig/trunk: CHANGES.txt
src/org/apache/pig/backend/hadoop/executionengine/mapReduceLayer/MapReduceLauncher.java
Author: cheolsoo
Date: Mon Nov 18 18:30:27 2013
New Revision: 1543100
URL: http://svn.apache.org/r1543100
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=1543100&r1=1543099&r2=1543100&view=diff
==============================================================================
--- pig/trunk/CHANGES.txt (original)
+++ pig/trunk/CHANGES.txt Mon Nov 18 18:30:27 2013
@@ -54,6 +54,8 @@ OPTIMIZATIONS
BUG FIXES
+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)
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=1543100&r1=1543099&r2=1543100&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 Mon Nov 18 18:30:27 2013
@@ -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: " + j.getAssignedJobID().toString() + " Reason: " + j.getMessage());
+ msg.append("JobID: " + String.valueOf(j.getAssignedJobID()) + " Reason: " + j.getMessage());
if (i!=jc.getFailedJobs().size()-1) {
msg.append("\n");
}