diff --git a/data/conf/llap/llap-daemon-site.xml b/data/conf/llap/llap-daemon-site.xml index f2851a7..4c13736 100644 --- a/data/conf/llap/llap-daemon-site.xml +++ b/data/conf/llap/llap-daemon-site.xml @@ -38,6 +38,11 @@ 4 + + llap.daemon.enable.web.services + false + + ipc.client.low-latency diff --git a/llap-client/src/java/org/apache/hadoop/hive/llap/configuration/LlapConfiguration.java b/llap-client/src/java/org/apache/hadoop/hive/llap/configuration/LlapConfiguration.java index bd09024..0f8b3f0 100644 --- a/llap-client/src/java/org/apache/hadoop/hive/llap/configuration/LlapConfiguration.java +++ b/llap-client/src/java/org/apache/hadoop/hive/llap/configuration/LlapConfiguration.java @@ -173,4 +173,8 @@ public LlapConfiguration(Configuration conf, URL llapDaemonConfLocation) { public static final String LLAP_DAEMON_SERVICE_SSL = LLAP_DAEMON_PREFIX + "service.ssl"; public static final boolean LLAP_DAEMON_SERVICE_SSL_DEFAULT = false; + + public static final String LLAP_DAEMON_ENABLE_WEB_SERVICES = + LLAP_DAEMON_PREFIX + "enable.web.services"; + public static final boolean LLAP_DAEMON_ENABLE_WEB_SERVICES_DEFAULT = true; } diff --git a/llap-server/src/java/org/apache/hadoop/hive/llap/daemon/impl/LlapDaemon.java b/llap-server/src/java/org/apache/hadoop/hive/llap/daemon/impl/LlapDaemon.java index 9139de6..8335256 100644 --- a/llap-server/src/java/org/apache/hadoop/hive/llap/daemon/impl/LlapDaemon.java +++ b/llap-server/src/java/org/apache/hadoop/hive/llap/daemon/impl/LlapDaemon.java @@ -177,8 +177,14 @@ public LlapDaemon(Configuration daemonConf, int numExecutors, long executorMemor this.registry = new LlapRegistryService(true); addIfService(registry); - this.webServices = new LlapWebServices(); - addIfService(webServices); + boolean enableWS = daemonConf.getBoolean(LlapConfiguration.LLAP_DAEMON_ENABLE_WEB_SERVICES, + LlapConfiguration.LLAP_DAEMON_ENABLE_WEB_SERVICES_DEFAULT); + if (enableWS) { + this.webServices = new LlapWebServices(); + addIfService(webServices); + } else { + this.webServices = null; + } // Bring up the server only after all other components have started. addIfService(server); // AMReporter after the server so that it gets the correct address. It knows how to deal with