azkaban-aplcache

undoing a wrong change in AzkabanExecutorServer, adding the

9/14/2015 10:06:24 PM

Details

diff --git a/azkaban-execserver/src/main/java/azkaban/execapp/AzkabanExecutorServer.java b/azkaban-execserver/src/main/java/azkaban/execapp/AzkabanExecutorServer.java
index 3a87616..0c5b9f7 100644
--- a/azkaban-execserver/src/main/java/azkaban/execapp/AzkabanExecutorServer.java
+++ b/azkaban-execserver/src/main/java/azkaban/execapp/AzkabanExecutorServer.java
@@ -149,7 +149,7 @@ public class AzkabanExecutorServer {
 
     SystemMemoryInfo.init(props.getInt("executor.memCheck.interval", 30));
 
-//    loadCustomJMXAttributeProcessor(props);
+    loadCustomJMXAttributeProcessor(props);
 
     try {
       server.start();
@@ -167,9 +167,9 @@ public class AzkabanExecutorServer {
 
     logger.info("Job callback enabled? " + jobCallbackEnabled);
 
-//    if (jobCallbackEnabled) {
-//      JobCallbackManager.initialize(props);
-//    }
+    if (jobCallbackEnabled) {
+      JobCallbackManager.initialize(props);
+    }
   }
 
   /**
@@ -445,11 +445,11 @@ public class AzkabanExecutorServer {
     registerMbean("flowRunnerManager", new JmxFlowRunnerManager(runnerManager));
     registerMbean("jobJMXMBean", JmxJobMBeanManager.getInstance());
 
-//    if (JobCallbackManager.isInitialized()) {
-//      JobCallbackManager jobCallbackMgr = JobCallbackManager.getInstance();
-//      registerMbean("jobCallbackJMXMBean",
-//          jobCallbackMgr.getJmxJobCallbackMBean());
-//    }
+    if (JobCallbackManager.isInitialized()) {
+      JobCallbackManager jobCallbackMgr = JobCallbackManager.getInstance();
+      registerMbean("jobCallbackJMXMBean",
+          jobCallbackMgr.getJmxJobCallbackMBean());
+    }
   }
 
   public void close() {
diff --git a/azkaban-execserver/src/main/resources/execute-as-user.c b/azkaban-execserver/src/main/resources/execute-as-user.c
index 273605c..22dbe3a 100644
--- a/azkaban-execserver/src/main/resources/execute-as-user.c
+++ b/azkaban-execserver/src/main/resources/execute-as-user.c
@@ -95,9 +95,9 @@ int main(int argc, char **argv){
         len = strlen(argv[i]);
         memcpy(cur, argv[i], len);
         cur+=len+1;
-        printf("%s\n", cmd);
     }
 
+    printf("executing command: %s\n", cmd);
     retval = system(cmd);
     fprintf(LOGFILE, "system call return value: %d", retval);