diff --git a/azkaban-exec-server/src/main/java/azkaban/execapp/AzkabanExecutorServer.java b/azkaban-exec-server/src/main/java/azkaban/execapp/AzkabanExecutorServer.java
index 195cb52..d583d59 100644
--- a/azkaban-exec-server/src/main/java/azkaban/execapp/AzkabanExecutorServer.java
+++ b/azkaban-exec-server/src/main/java/azkaban/execapp/AzkabanExecutorServer.java
@@ -16,8 +16,8 @@
package azkaban.execapp;
-import static azkaban.Constants.DEFAULT_EXECUTOR_PORT_FILE;
import static azkaban.Constants.ConfigurationKeys;
+import static azkaban.Constants.DEFAULT_EXECUTOR_PORT_FILE;
import static azkaban.ServiceProvider.SERVICE_PROVIDER;
import static azkaban.execapp.ExecJettyServerModule.EXEC_JETTY_SERVER;
import static azkaban.execapp.ExecJettyServerModule.EXEC_ROOT_CONTEXT;
@@ -174,34 +174,34 @@ public class AzkabanExecutorServer {
try {
logTopMemoryConsumers();
} catch (final Exception e) {
- logger.info(("Exception when logging top memory consumers"), e);
+ AzkabanExecutorServer.logger.info(("Exception when logging top memory consumers"), e);
}
- final String host = app.getHost();
- final int port = app.getPort();
+ final String host = AzkabanExecutorServer.app.getHost();
+ final int port = AzkabanExecutorServer.app.getPort();
try {
- logger.info(String
+ AzkabanExecutorServer.logger.info(String
.format("Removing executor(host: %s, port: %s) entry from database...", host, port));
- app.getExecutorLoader().removeExecutor(host, port);
+ AzkabanExecutorServer.app.getExecutorLoader().removeExecutor(host, port);
} catch (final ExecutorManagerException ex) {
- logger.error(
+ AzkabanExecutorServer.logger.error(
String.format("Exception when removing executor(host: %s, port: %s)", host, port),
ex);
}
- logger.warn("Shutting down executor...");
+ AzkabanExecutorServer.logger.warn("Shutting down executor...");
try {
- app.shutdownNow();
- app.getFlowRunnerManager().deleteExecutionDirectory();
+ AzkabanExecutorServer.app.shutdownNow();
+ AzkabanExecutorServer.app.getFlowRunnerManager().deleteExecutionDirectory();
} catch (final Exception e) {
- logger.error("Error while shutting down http server.", e);
+ AzkabanExecutorServer.logger.error("Error while shutting down http server.", e);
}
}
public void logTopMemoryConsumers() throws Exception, IOException {
if (new File("/bin/bash").exists() && new File("/bin/ps").exists()
&& new File("/usr/bin/head").exists()) {
- logger.info("logging top memory consumer");
+ AzkabanExecutorServer.logger.info("logging top memory consumer");
final java.lang.ProcessBuilder processBuilder =
new java.lang.ProcessBuilder("/bin/bash", "-c",
@@ -214,7 +214,7 @@ public class AzkabanExecutorServer {
new java.io.BufferedReader(new InputStreamReader(is, StandardCharsets.UTF_8));
String line = null;
while ((line = reader.readLine()) != null) {
- logger.info(line);
+ AzkabanExecutorServer.logger.info(line);
}
is.close();
}