azkaban-aplcache

Running SaveAction on ProcessJob (#1319) Working on a bug

8/9/2017 5:13:59 PM

Details

diff --git a/azkaban-common/src/main/java/azkaban/jobExecutor/ProcessJob.java b/azkaban-common/src/main/java/azkaban/jobExecutor/ProcessJob.java
index d26bb10..feed8c1 100644
--- a/azkaban-common/src/main/java/azkaban/jobExecutor/ProcessJob.java
+++ b/azkaban-common/src/main/java/azkaban/jobExecutor/ProcessJob.java
@@ -224,13 +224,13 @@ public class ProcessJob extends AbstractProcessJob {
       final String nativeLibFolder = this.sysProps.getString(NATIVE_LIB_FOLDER);
       executeAsUserBinaryPath = String.format("%s/%s", nativeLibFolder, "execute-as-user");
       effectiveUser = getEffectiveUser(this.jobProps);
-        // Throw exception if Azkaban tries to run flow as a prohibited user
-        if (blackListedUsers.contains(effectiveUser)) {
-          throw new RuntimeException(
-              String.format("Not permitted to proxy as '%s' through Azkaban", effectiveUser)
-          );
-        }
+      // Throw exception if Azkaban tries to run flow as a prohibited user
+      if (blackListedUsers.contains(effectiveUser)) {
+        throw new RuntimeException(
+            String.format("Not permitted to proxy as '%s' through Azkaban", effectiveUser)
+        );
       }
+    }
 
     for (String command : commands) {
       AzkabanProcessBuilder builder = null;