Merge pull request #206 from johnyu0520/master

HadoopSecurePigWrapper has a special feature that reads the pig log f…
azkaban · Nov 6, 2015 · c22c3dd · c22c3dd
2 parents fc3651f + 0cdcb4f
commit c22c3dd
Showing 1 changed file with 4 additions and 0 deletions.
diff --git a/plugins/jobtype/src/azkaban/jobtype/HadoopSecurePigWrapper.java b/plugins/jobtype/src/azkaban/jobtype/HadoopSecurePigWrapper.java
@@ -57,6 +57,10 @@ public static void main(final String[] args) throws Exception {
     Properties jobProps = HadoopSecureWrapperUtils.loadAzkabanProps();
     props = new Props(null, jobProps);
     HadoopConfigurationInjector.injectResources(props);
+
+    // special feature of secure pig wrapper: we will append the pig error file
+    // onto system out
+    pigLogFile = new File(System.getenv("PIG_LOG_FILE"));
 
     if (HadoopSecureWrapperUtils.shouldProxy(jobProps)) {
       String tokenFile = System.getenv(HADOOP_TOKEN_FILE_LOCATION);