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);