svn commit: r1437850 - in /oozie/trunk/core/src/main/java/org/apache/oozie/action/hadoop: LauncherMapper.java PigActionExecutor.java

[mona]

Author: mona
Date: Thu Jan 24 03:16:26 2013
New Revision: 1437850

URL: http://svn.apache.org/viewvc?rev=1437850&view=rev
Log:
OOZIE-1160 additional minor review comments

Modified:
    
oozie/trunk/core/src/main/java/org/apache/oozie/action/hadoop/LauncherMapper.java
    
oozie/trunk/core/src/main/java/org/apache/oozie/action/hadoop/PigActionExecutor.java

Modified: 
oozie/trunk/core/src/main/java/org/apache/oozie/action/hadoop/LauncherMapper.java
URL: 
http://svn.apache.org/viewvc/oozie/trunk/core/src/main/java/org/apache/oozie/action/hadoop/LauncherMapper.java?rev=1437850&r1=1437849&r2=1437850&view=diff
==============================================================================
--- 
oozie/trunk/core/src/main/java/org/apache/oozie/action/hadoop/LauncherMapper.java
 (original)
+++ 
oozie/trunk/core/src/main/java/org/apache/oozie/action/hadoop/LauncherMapper.java
 Thu Jan 24 03:16:26 2013
@@ -547,7 +547,6 @@ public class LauncherMapper<K1, V1, K2, 
                             System.out.println();
                         }
                         handleActionStatsData(reporter);
-                        handleExternalChildIDs(reporter);
                         File newId = new 
File(System.getProperty("oozie.action.newId.properties"));
                         if (newId.exists()) {
                             Properties props = new Properties();

Modified: 
oozie/trunk/core/src/main/java/org/apache/oozie/action/hadoop/PigActionExecutor.java
URL: 
http://svn.apache.org/viewvc/oozie/trunk/core/src/main/java/org/apache/oozie/action/hadoop/PigActionExecutor.java?rev=1437850&r1=1437849&r2=1437850&view=diff
==============================================================================
--- 
oozie/trunk/core/src/main/java/org/apache/oozie/action/hadoop/PigActionExecutor.java
 (original)
+++ 
oozie/trunk/core/src/main/java/org/apache/oozie/action/hadoop/PigActionExecutor.java
 Thu Jan 24 03:16:26 2013
@@ -174,10 +174,7 @@ public class PigActionExecutor extends J
     protected void setActionCompletionData(Context context, FileSystem fs) 
throws HadoopAccessorException, IOException,
             URISyntaxException {
         String data = getExternalChildIDs(context, fs);
-        if (data != null && !data.isEmpty()) {
-            context.setExternalChildIDs(data);
-            XLog.getLog(getClass()).info(XLog.STD, "Hadoop Jobs launched : 
[{0}]", data);
-        }
+        context.setExternalChildIDs(data);
     }
 
     private String getExternalChildIDs(Context context, FileSystem actionFs) 
throws IOException,
@@ -186,6 +183,7 @@ public class PigActionExecutor extends J
         String externalIDs = null;
         if (actionFs.exists(actionOutput)) {
             externalIDs = getDataFromPath(actionOutput, actionFs);
+            XLog.getLog(getClass()).info(XLog.STD, "Hadoop Jobs launched : 
[{0}]", externalIDs);
         }
         return externalIDs;
     }