You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@ambari.apache.org by jo...@apache.org on 2017/08/10 17:49:09 UTC
[24/50] [abbrv] ambari git commit: AMBARI-21581 - Replace Hard Coded
conf-select Structures (jonathanhurley)
http://git-wip-us.apache.org/repos/asf/ambari/blob/0535ca64/ambari-server/src/main/resources/common-services/SPARK/1.2.1/package/scripts/livy_server.py
----------------------------------------------------------------------
diff --git a/ambari-server/src/main/resources/common-services/SPARK/1.2.1/package/scripts/livy_server.py b/ambari-server/src/main/resources/common-services/SPARK/1.2.1/package/scripts/livy_server.py
index 0ac1679..4065d66 100644
--- a/ambari-server/src/main/resources/common-services/SPARK/1.2.1/package/scripts/livy_server.py
+++ b/ambari-server/src/main/resources/common-services/SPARK/1.2.1/package/scripts/livy_server.py
@@ -31,7 +31,7 @@ from resource_management import shell
from resource_management.libraries.functions.decorator import retry
from resource_management.core.logger import Logger
from resource_management.libraries.functions.format import format
-from resource_management.libraries.functions import conf_select, stack_select
+from resource_management.libraries.functions import stack_select
from livy_service import livy_service
from setup_livy import setup_livy
@@ -128,7 +128,6 @@ class LivyServer(Script):
env.set_params(params)
if params.version and check_stack_feature(StackFeature.ROLLING_UPGRADE, params.version):
Logger.info("Executing Livy Server Stack Upgrade pre-restart")
- conf_select.select(params.stack_name, "spark", params.version)
stack_select.select_packages(params.version)
def get_log_folder(self):
http://git-wip-us.apache.org/repos/asf/ambari/blob/0535ca64/ambari-server/src/main/resources/common-services/SPARK/1.2.1/package/scripts/spark_client.py
----------------------------------------------------------------------
diff --git a/ambari-server/src/main/resources/common-services/SPARK/1.2.1/package/scripts/spark_client.py b/ambari-server/src/main/resources/common-services/SPARK/1.2.1/package/scripts/spark_client.py
index a2e26b8..8136a18 100644
--- a/ambari-server/src/main/resources/common-services/SPARK/1.2.1/package/scripts/spark_client.py
+++ b/ambari-server/src/main/resources/common-services/SPARK/1.2.1/package/scripts/spark_client.py
@@ -23,7 +23,7 @@ import sys
# Local imports
from resource_management.libraries.script.script import Script
-from resource_management.libraries.functions import conf_select, stack_select
+from resource_management.libraries.functions import stack_select
from resource_management.libraries.functions.stack_features import check_stack_feature
from resource_management.libraries.functions.constants import StackFeature
from resource_management.core.exceptions import ClientComponentHasNoStatus
@@ -69,7 +69,6 @@ class SparkClient(Script):
# Because this script was called from ru_execute_tasks.py which already enters an Environment with its own basedir,
# must change it now so this function can find the Jinja Templates for the service.
env.config.basedir = base_dir
- conf_select.select(params.stack_name, conf_select_name, params.version)
self.configure(env, config_dir=config_dir, upgrade_type=UPGRADE_TYPE_ROLLING)
def pre_upgrade_restart(self, env, upgrade_type=None):
@@ -78,7 +77,6 @@ class SparkClient(Script):
env.set_params(params)
if params.version and check_stack_feature(StackFeature.ROLLING_UPGRADE, params.version):
Logger.info("Executing Spark Client Stack Upgrade pre-restart")
- conf_select.select(params.stack_name, "spark", params.version)
stack_select.select_packages(params.version)
if __name__ == "__main__":
http://git-wip-us.apache.org/repos/asf/ambari/blob/0535ca64/ambari-server/src/main/resources/common-services/SPARK/1.2.1/package/scripts/spark_thrift_server.py
----------------------------------------------------------------------
diff --git a/ambari-server/src/main/resources/common-services/SPARK/1.2.1/package/scripts/spark_thrift_server.py b/ambari-server/src/main/resources/common-services/SPARK/1.2.1/package/scripts/spark_thrift_server.py
index 44a156f..1581453 100644
--- a/ambari-server/src/main/resources/common-services/SPARK/1.2.1/package/scripts/spark_thrift_server.py
+++ b/ambari-server/src/main/resources/common-services/SPARK/1.2.1/package/scripts/spark_thrift_server.py
@@ -22,7 +22,6 @@ import sys
import os
from resource_management.libraries.script.script import Script
-from resource_management.libraries.functions import conf_select
from resource_management.libraries.functions import stack_select
from resource_management.libraries.functions.stack_features import check_stack_feature
from resource_management.libraries.functions import StackFeature
@@ -69,7 +68,6 @@ class SparkThriftServer(Script):
env.set_params(params)
if params.version and check_stack_feature(StackFeature.ROLLING_UPGRADE, params.version):
Logger.info("Executing Spark Thrift Server Stack Upgrade pre-restart")
- conf_select.select(params.stack_name, "spark", params.version)
stack_select.select_packages(params.version)
def get_log_folder(self):
http://git-wip-us.apache.org/repos/asf/ambari/blob/0535ca64/ambari-server/src/main/resources/common-services/SPARK2/2.0.0/package/scripts/job_history_server.py
----------------------------------------------------------------------
diff --git a/ambari-server/src/main/resources/common-services/SPARK2/2.0.0/package/scripts/job_history_server.py b/ambari-server/src/main/resources/common-services/SPARK2/2.0.0/package/scripts/job_history_server.py
index 793ffa3..5da4863 100755
--- a/ambari-server/src/main/resources/common-services/SPARK2/2.0.0/package/scripts/job_history_server.py
+++ b/ambari-server/src/main/resources/common-services/SPARK2/2.0.0/package/scripts/job_history_server.py
@@ -22,7 +22,6 @@ import sys
import os
from resource_management.libraries.script.script import Script
-from resource_management.libraries.functions import conf_select
from resource_management.libraries.functions import stack_select
from resource_management.libraries.functions.copy_tarball import copy_to_hdfs
from resource_management.libraries.functions.check_process_status import check_process_status
@@ -74,7 +73,6 @@ class JobHistoryServer(Script):
env.set_params(params)
if params.version and check_stack_feature(StackFeature.ROLLING_UPGRADE, params.version):
Logger.info("Executing Spark2 Job History Server Stack Upgrade pre-restart")
- conf_select.select(params.stack_name, "spark2", params.version)
stack_select.select_packages(params.version)
# Spark 1.3.1.2.3, and higher, which was included in HDP 2.3, does not have a dependency on Tez, so it does not
http://git-wip-us.apache.org/repos/asf/ambari/blob/0535ca64/ambari-server/src/main/resources/common-services/SPARK2/2.0.0/package/scripts/livy2_server.py
----------------------------------------------------------------------
diff --git a/ambari-server/src/main/resources/common-services/SPARK2/2.0.0/package/scripts/livy2_server.py b/ambari-server/src/main/resources/common-services/SPARK2/2.0.0/package/scripts/livy2_server.py
index c710757..50604d4 100644
--- a/ambari-server/src/main/resources/common-services/SPARK2/2.0.0/package/scripts/livy2_server.py
+++ b/ambari-server/src/main/resources/common-services/SPARK2/2.0.0/package/scripts/livy2_server.py
@@ -31,7 +31,7 @@ from resource_management import shell
from resource_management.libraries.functions.decorator import retry
from resource_management.core.logger import Logger
from resource_management.libraries.functions.format import format
-from resource_management.libraries.functions import conf_select, stack_select
+from resource_management.libraries.functions import stack_select
from livy2_service import livy2_service
from setup_livy2 import setup_livy
@@ -131,7 +131,6 @@ class LivyServer(Script):
env.set_params(params)
if params.version and check_stack_feature(StackFeature.ROLLING_UPGRADE, params.version):
Logger.info("Executing Livy2 Server Stack Upgrade pre-restart")
- conf_select.select(params.stack_name, "spark2", params.version)
stack_select.select_packages(params.version)
def get_log_folder(self):
http://git-wip-us.apache.org/repos/asf/ambari/blob/0535ca64/ambari-server/src/main/resources/common-services/SPARK2/2.0.0/package/scripts/spark_client.py
----------------------------------------------------------------------
diff --git a/ambari-server/src/main/resources/common-services/SPARK2/2.0.0/package/scripts/spark_client.py b/ambari-server/src/main/resources/common-services/SPARK2/2.0.0/package/scripts/spark_client.py
index 1db4429..782a6c4 100755
--- a/ambari-server/src/main/resources/common-services/SPARK2/2.0.0/package/scripts/spark_client.py
+++ b/ambari-server/src/main/resources/common-services/SPARK2/2.0.0/package/scripts/spark_client.py
@@ -20,7 +20,6 @@ limitations under the License.
import sys
from resource_management import *
-from resource_management.libraries.functions import conf_select
from resource_management.libraries.functions import stack_select
from resource_management.libraries.functions.stack_features import check_stack_feature
from resource_management.libraries.functions import StackFeature
@@ -50,7 +49,6 @@ class SparkClient(Script):
env.set_params(params)
if params.version and check_stack_feature(StackFeature.ROLLING_UPGRADE, params.version):
Logger.info("Executing Spark2 Client Stack Upgrade pre-restart")
- conf_select.select(params.stack_name, "spark", params.version)
stack_select.select_packages(params.version)
if __name__ == "__main__":
http://git-wip-us.apache.org/repos/asf/ambari/blob/0535ca64/ambari-server/src/main/resources/common-services/SPARK2/2.0.0/package/scripts/spark_thrift_server.py
----------------------------------------------------------------------
diff --git a/ambari-server/src/main/resources/common-services/SPARK2/2.0.0/package/scripts/spark_thrift_server.py b/ambari-server/src/main/resources/common-services/SPARK2/2.0.0/package/scripts/spark_thrift_server.py
index e0dc11d..20b259d 100755
--- a/ambari-server/src/main/resources/common-services/SPARK2/2.0.0/package/scripts/spark_thrift_server.py
+++ b/ambari-server/src/main/resources/common-services/SPARK2/2.0.0/package/scripts/spark_thrift_server.py
@@ -22,7 +22,6 @@ import sys
import os
from resource_management.libraries.script.script import Script
-from resource_management.libraries.functions import conf_select
from resource_management.libraries.functions import stack_select
from resource_management.libraries.functions.stack_features import check_stack_feature
from resource_management.libraries.functions import StackFeature
@@ -68,7 +67,6 @@ class SparkThriftServer(Script):
env.set_params(params)
Logger.info("Executing Spark2 Thrift Server Stack Upgrade pre-restart")
- conf_select.select(params.stack_name, "spark2", params.version)
stack_select.select_packages(params.version)
def get_log_folder(self):
http://git-wip-us.apache.org/repos/asf/ambari/blob/0535ca64/ambari-server/src/main/resources/common-services/SQOOP/1.4.4.2.0/package/scripts/sqoop_client.py
----------------------------------------------------------------------
diff --git a/ambari-server/src/main/resources/common-services/SQOOP/1.4.4.2.0/package/scripts/sqoop_client.py b/ambari-server/src/main/resources/common-services/SQOOP/1.4.4.2.0/package/scripts/sqoop_client.py
index 8c7dd35..6c637b9 100644
--- a/ambari-server/src/main/resources/common-services/SQOOP/1.4.4.2.0/package/scripts/sqoop_client.py
+++ b/ambari-server/src/main/resources/common-services/SQOOP/1.4.4.2.0/package/scripts/sqoop_client.py
@@ -22,7 +22,6 @@ from resource_management.core.exceptions import ClientComponentHasNoStatus
from resource_management.core.resources.system import Execute
from resource_management.libraries.functions.default import default
from resource_management.libraries.script.script import Script
-from resource_management.libraries.functions import conf_select
from resource_management.libraries.functions import stack_select
from resource_management.libraries.functions.format import format
from resource_management.libraries.functions import StackFeature
@@ -50,8 +49,7 @@ class SqoopClientDefault(SqoopClient):
import params
env.set_params(params)
- if params.version and check_stack_feature(StackFeature.ROLLING_UPGRADE, params.version):
- conf_select.select(params.stack_name, "sqoop", params.version)
+ if params.version and check_stack_feature(StackFeature.ROLLING_UPGRADE, params.version):
stack_select.select_packages(params.version)
http://git-wip-us.apache.org/repos/asf/ambari/blob/0535ca64/ambari-server/src/main/resources/common-services/STORM/0.9.1/package/scripts/drpc_server.py
----------------------------------------------------------------------
diff --git a/ambari-server/src/main/resources/common-services/STORM/0.9.1/package/scripts/drpc_server.py b/ambari-server/src/main/resources/common-services/STORM/0.9.1/package/scripts/drpc_server.py
index 7da3fa1..507b7d8 100644
--- a/ambari-server/src/main/resources/common-services/STORM/0.9.1/package/scripts/drpc_server.py
+++ b/ambari-server/src/main/resources/common-services/STORM/0.9.1/package/scripts/drpc_server.py
@@ -21,7 +21,6 @@ limitations under the License.
import sys
from resource_management.libraries.functions import check_process_status
from resource_management.libraries.script import Script
-from resource_management.libraries.functions import conf_select
from resource_management.libraries.functions import stack_select
from resource_management.libraries.functions import format
from resource_management.core.resources.system import Execute
@@ -51,7 +50,6 @@ class DrpcServer(Script):
env.set_params(params)
if params.version and check_stack_feature(StackFeature.ROLLING_UPGRADE, params.version):
- conf_select.select(params.stack_name, "storm", params.version)
stack_select.select_packages(params.version)
def start(self, env, upgrade_type=None):
http://git-wip-us.apache.org/repos/asf/ambari/blob/0535ca64/ambari-server/src/main/resources/common-services/STORM/0.9.1/package/scripts/nimbus.py
----------------------------------------------------------------------
diff --git a/ambari-server/src/main/resources/common-services/STORM/0.9.1/package/scripts/nimbus.py b/ambari-server/src/main/resources/common-services/STORM/0.9.1/package/scripts/nimbus.py
index 53b965e..a941cf8 100644
--- a/ambari-server/src/main/resources/common-services/STORM/0.9.1/package/scripts/nimbus.py
+++ b/ambari-server/src/main/resources/common-services/STORM/0.9.1/package/scripts/nimbus.py
@@ -22,7 +22,6 @@ import sys
from resource_management.libraries.functions import check_process_status
from resource_management.libraries.script import Script
from resource_management.libraries.functions import format
-from resource_management.libraries.functions import conf_select
from resource_management.libraries.functions import stack_select
from resource_management.core.resources.system import Execute
from resource_management.libraries.functions.stack_features import check_stack_feature
@@ -55,7 +54,6 @@ class NimbusDefault(Nimbus):
import params
env.set_params(params)
if params.version and check_stack_feature(StackFeature.ROLLING_UPGRADE, params.version):
- conf_select.select(params.stack_name, "storm", params.version)
stack_select.select_packages(params.version)
def start(self, env, upgrade_type=None):
http://git-wip-us.apache.org/repos/asf/ambari/blob/0535ca64/ambari-server/src/main/resources/common-services/STORM/0.9.1/package/scripts/nimbus_prod.py
----------------------------------------------------------------------
diff --git a/ambari-server/src/main/resources/common-services/STORM/0.9.1/package/scripts/nimbus_prod.py b/ambari-server/src/main/resources/common-services/STORM/0.9.1/package/scripts/nimbus_prod.py
index 18d8fea..26c23d4 100644
--- a/ambari-server/src/main/resources/common-services/STORM/0.9.1/package/scripts/nimbus_prod.py
+++ b/ambari-server/src/main/resources/common-services/STORM/0.9.1/package/scripts/nimbus_prod.py
@@ -22,7 +22,6 @@ import sys
from resource_management.libraries.script import Script
from storm import storm
from supervisord_service import supervisord_service, supervisord_check_status
-from resource_management.libraries.functions import conf_select
from resource_management.libraries.functions import stack_select
from resource_management.libraries.functions import format
from resource_management.core.resources.system import Execute
@@ -46,7 +45,6 @@ class Nimbus(Script):
env.set_params(params)
if params.version and check_stack_feature(StackFeature.ROLLING_UPGRADE, params.version):
- conf_select.select(params.stack_name, "storm", params.version)
stack_select.select_packages(params.version)
def start(self, env, upgrade_type=None):
http://git-wip-us.apache.org/repos/asf/ambari/blob/0535ca64/ambari-server/src/main/resources/common-services/STORM/0.9.1/package/scripts/pacemaker.py
----------------------------------------------------------------------
diff --git a/ambari-server/src/main/resources/common-services/STORM/0.9.1/package/scripts/pacemaker.py b/ambari-server/src/main/resources/common-services/STORM/0.9.1/package/scripts/pacemaker.py
index fc45bc1..da7fff0 100644
--- a/ambari-server/src/main/resources/common-services/STORM/0.9.1/package/scripts/pacemaker.py
+++ b/ambari-server/src/main/resources/common-services/STORM/0.9.1/package/scripts/pacemaker.py
@@ -21,7 +21,6 @@ limitations under the License.
import sys
from resource_management.libraries.functions import check_process_status
from resource_management.libraries.script import Script
-from resource_management.libraries.functions import conf_select
from resource_management.libraries.functions import stack_select
from resource_management.libraries.functions import format
from resource_management.core.resources.system import Execute
@@ -50,7 +49,6 @@ class PaceMaker(Script):
env.set_params(params)
if params.version and check_stack_feature(StackFeature.ROLLING_UPGRADE, params.version):
- conf_select.select(params.stack_name, "storm", params.version)
stack_select.select_packages(params.version)
def start(self, env, upgrade_type=None):
http://git-wip-us.apache.org/repos/asf/ambari/blob/0535ca64/ambari-server/src/main/resources/common-services/STORM/0.9.1/package/scripts/supervisor.py
----------------------------------------------------------------------
diff --git a/ambari-server/src/main/resources/common-services/STORM/0.9.1/package/scripts/supervisor.py b/ambari-server/src/main/resources/common-services/STORM/0.9.1/package/scripts/supervisor.py
index 318bd0b..05b05ab 100644
--- a/ambari-server/src/main/resources/common-services/STORM/0.9.1/package/scripts/supervisor.py
+++ b/ambari-server/src/main/resources/common-services/STORM/0.9.1/package/scripts/supervisor.py
@@ -21,7 +21,6 @@ limitations under the License.
import sys
from resource_management.libraries.functions import check_process_status
from resource_management.libraries.script import Script
-from resource_management.libraries.functions import conf_select
from resource_management.libraries.functions import stack_select
from resource_management.libraries.functions import format
from resource_management.core.resources.system import Execute
@@ -73,7 +72,6 @@ class SupervisorDefault(Supervisor):
env.set_params(params)
if params.version and check_stack_feature(StackFeature.ROLLING_UPGRADE, params.version):
- conf_select.select(params.stack_name, "storm", params.version)
stack_select.select_packages(params.version)
def start(self, env, upgrade_type=None):
http://git-wip-us.apache.org/repos/asf/ambari/blob/0535ca64/ambari-server/src/main/resources/common-services/STORM/0.9.1/package/scripts/supervisor_prod.py
----------------------------------------------------------------------
diff --git a/ambari-server/src/main/resources/common-services/STORM/0.9.1/package/scripts/supervisor_prod.py b/ambari-server/src/main/resources/common-services/STORM/0.9.1/package/scripts/supervisor_prod.py
index 46626bc..c98346b 100644
--- a/ambari-server/src/main/resources/common-services/STORM/0.9.1/package/scripts/supervisor_prod.py
+++ b/ambari-server/src/main/resources/common-services/STORM/0.9.1/package/scripts/supervisor_prod.py
@@ -23,7 +23,6 @@ from storm import storm
from service import service
from supervisord_service import supervisord_service, supervisord_check_status
from resource_management.libraries.script import Script
-from resource_management.libraries.functions import conf_select
from resource_management.libraries.functions import stack_select
from resource_management.libraries.functions import format
from resource_management.core.resources.system import Execute
@@ -47,7 +46,6 @@ class Supervisor(Script):
env.set_params(params)
if params.version and check_stack_feature(StackFeature.ROLLING_UPGRADE, params.version):
- conf_select.select(params.stack_name, "storm", params.version)
stack_select.select_packages(params.version)
def start(self, env, upgrade_type=None):
http://git-wip-us.apache.org/repos/asf/ambari/blob/0535ca64/ambari-server/src/main/resources/common-services/STORM/0.9.1/package/scripts/ui_server.py
----------------------------------------------------------------------
diff --git a/ambari-server/src/main/resources/common-services/STORM/0.9.1/package/scripts/ui_server.py b/ambari-server/src/main/resources/common-services/STORM/0.9.1/package/scripts/ui_server.py
index 90ec64c..3feb632 100644
--- a/ambari-server/src/main/resources/common-services/STORM/0.9.1/package/scripts/ui_server.py
+++ b/ambari-server/src/main/resources/common-services/STORM/0.9.1/package/scripts/ui_server.py
@@ -24,7 +24,6 @@ from service import service
from service_check import ServiceCheck
from resource_management.libraries.functions import check_process_status
from resource_management.libraries.script import Script
-from resource_management.libraries.functions import conf_select
from resource_management.libraries.functions import stack_select
from resource_management.libraries.functions import format
from resource_management.core.resources.system import Link
@@ -78,7 +77,6 @@ class UiServerDefault(UiServer):
import params
env.set_params(params)
if params.version and check_stack_feature(StackFeature.ROLLING_UPGRADE, params.version):
- conf_select.select(params.stack_name, "storm", params.version)
stack_select.select_packages(params.version)
def link_metrics_sink_jar(self):
http://git-wip-us.apache.org/repos/asf/ambari/blob/0535ca64/ambari-server/src/main/resources/common-services/TEZ/0.4.0.2.1/package/scripts/tez_client.py
----------------------------------------------------------------------
diff --git a/ambari-server/src/main/resources/common-services/TEZ/0.4.0.2.1/package/scripts/tez_client.py b/ambari-server/src/main/resources/common-services/TEZ/0.4.0.2.1/package/scripts/tez_client.py
index 8a6a6d3..ed3f5fd 100644
--- a/ambari-server/src/main/resources/common-services/TEZ/0.4.0.2.1/package/scripts/tez_client.py
+++ b/ambari-server/src/main/resources/common-services/TEZ/0.4.0.2.1/package/scripts/tez_client.py
@@ -28,7 +28,6 @@ from ambari_commons.os_utils import copy_file, extract_path_component
from resource_management.core.exceptions import ClientComponentHasNoStatus
from resource_management.core.source import InlineTemplate
-from resource_management.libraries.functions import conf_select
from resource_management.libraries.functions import stack_select
from resource_management.libraries.functions import StackFeature
from resource_management.libraries.functions.stack_features import check_stack_feature
@@ -72,12 +71,9 @@ class TezClientLinux(TezClient):
config_dir = self.get_config_dir_during_stack_upgrade(env, base_dir, conf_select_name)
if config_dir:
- Logger.info("stack_upgrade_save_new_config(): Calling conf-select on %s using version %s" % (conf_select_name, str(params.version)))
-
# Because this script was called from ru_execute_tasks.py which already enters an Environment with its own basedir,
# must change it now so this function can find the Jinja Templates for the service.
env.config.basedir = base_dir
- conf_select.select(params.stack_name, conf_select_name, params.version)
self.configure(env, config_dir=config_dir)
def pre_upgrade_restart(self, env, upgrade_type=None):
@@ -85,8 +81,6 @@ class TezClientLinux(TezClient):
env.set_params(params)
if params.version and check_stack_feature(StackFeature.ROLLING_UPGRADE, params.version):
- conf_select.select(params.stack_name, "tez", params.version)
- conf_select.select(params.stack_name, "hadoop", params.version)
stack_select.select_packages(params.version)
def install(self, env):
http://git-wip-us.apache.org/repos/asf/ambari/blob/0535ca64/ambari-server/src/main/resources/common-services/TITAN/1.0.0/package/scripts/titan_client.py
----------------------------------------------------------------------
diff --git a/ambari-server/src/main/resources/common-services/TITAN/1.0.0/package/scripts/titan_client.py b/ambari-server/src/main/resources/common-services/TITAN/1.0.0/package/scripts/titan_client.py
index 2d0a93e..ea0d034 100755
--- a/ambari-server/src/main/resources/common-services/TITAN/1.0.0/package/scripts/titan_client.py
+++ b/ambari-server/src/main/resources/common-services/TITAN/1.0.0/package/scripts/titan_client.py
@@ -22,7 +22,6 @@ Ambari Agent
import sys
import os
from resource_management import *
-from resource_management.libraries.functions import conf_select
from resource_management.libraries.functions import stack_select
from resource_management.libraries.functions import StackFeature
from resource_management.libraries.functions.stack_features import check_stack_feature
@@ -47,7 +46,6 @@ class TitanClientLinux(TitanClient):
env.set_params(params)
if params.version and check_stack_feature(StackFeature.ROLLING_UPGRADE, params.version):
- conf_select.select(params.stack_name, "titan", params.version)
stack_select.select_packages(params.version)
def install(self, env):
http://git-wip-us.apache.org/repos/asf/ambari/blob/0535ca64/ambari-server/src/main/resources/common-services/TITAN/1.0.0/package/scripts/titan_server.py
----------------------------------------------------------------------
diff --git a/ambari-server/src/main/resources/common-services/TITAN/1.0.0/package/scripts/titan_server.py b/ambari-server/src/main/resources/common-services/TITAN/1.0.0/package/scripts/titan_server.py
index 427448b..187667e 100755
--- a/ambari-server/src/main/resources/common-services/TITAN/1.0.0/package/scripts/titan_server.py
+++ b/ambari-server/src/main/resources/common-services/TITAN/1.0.0/package/scripts/titan_server.py
@@ -20,7 +20,6 @@ limitations under the License.
import sys
from resource_management import *
-from resource_management.libraries.functions import conf_select
from resource_management.libraries.functions import stack_select
from resource_management.libraries.functions import StackFeature
from resource_management.libraries.functions.stack_features import check_stack_feature
@@ -43,7 +42,6 @@ class TitanServer(Script):
env.set_params(params)
if params.version and check_stack_feature(StackFeature.ROLLING_UPGRADE, params.version):
stack_select.select_packages(params.version)
- conf_select.select(params.stack_name, "titan", params.version)
def start(self, env, upgrade_type=None):
import params
http://git-wip-us.apache.org/repos/asf/ambari/blob/0535ca64/ambari-server/src/main/resources/common-services/YARN/2.1.0.2.0/package/scripts/application_timeline_server.py
----------------------------------------------------------------------
diff --git a/ambari-server/src/main/resources/common-services/YARN/2.1.0.2.0/package/scripts/application_timeline_server.py b/ambari-server/src/main/resources/common-services/YARN/2.1.0.2.0/package/scripts/application_timeline_server.py
index c4f3cfe..6c43c13 100644
--- a/ambari-server/src/main/resources/common-services/YARN/2.1.0.2.0/package/scripts/application_timeline_server.py
+++ b/ambari-server/src/main/resources/common-services/YARN/2.1.0.2.0/package/scripts/application_timeline_server.py
@@ -20,7 +20,6 @@ Ambari Agent
"""
from resource_management import *
-from resource_management.libraries.functions import conf_select
from resource_management.libraries.functions import stack_select
from resource_management.libraries.functions import StackFeature
from resource_management.libraries.functions.stack_features import check_stack_feature
@@ -69,7 +68,6 @@ class ApplicationTimelineServerDefault(ApplicationTimelineServer):
env.set_params(params)
if params.version and check_stack_feature(StackFeature.ROLLING_UPGRADE, params.version):
- conf_select.select(params.stack_name, "hadoop", params.version)
stack_select.select_packages(params.version)
def status(self, env):
http://git-wip-us.apache.org/repos/asf/ambari/blob/0535ca64/ambari-server/src/main/resources/common-services/YARN/2.1.0.2.0/package/scripts/historyserver.py
----------------------------------------------------------------------
diff --git a/ambari-server/src/main/resources/common-services/YARN/2.1.0.2.0/package/scripts/historyserver.py b/ambari-server/src/main/resources/common-services/YARN/2.1.0.2.0/package/scripts/historyserver.py
index ff50e4e..7950cca 100644
--- a/ambari-server/src/main/resources/common-services/YARN/2.1.0.2.0/package/scripts/historyserver.py
+++ b/ambari-server/src/main/resources/common-services/YARN/2.1.0.2.0/package/scripts/historyserver.py
@@ -21,7 +21,6 @@ Ambari Agent
from resource_management.libraries.script.script import Script
from resource_management.libraries.resources.hdfs_resource import HdfsResource
-from resource_management.libraries.functions import conf_select
from resource_management.libraries.functions import stack_select
from resource_management.libraries.functions import StackFeature
from resource_management.libraries.functions.stack_features import check_stack_feature
@@ -76,7 +75,6 @@ class HistoryServerDefault(HistoryServer):
env.set_params(params)
if params.version and check_stack_feature(StackFeature.ROLLING_UPGRADE, params.version):
- conf_select.select(params.stack_name, "hadoop", params.version)
stack_select.select_packages(params.version)
# MC Hammer said, "Can't touch this"
copy_to_hdfs("mapreduce", params.user_group, params.hdfs_user, skip=params.sysprep_skip_copy_tarballs_hdfs)
http://git-wip-us.apache.org/repos/asf/ambari/blob/0535ca64/ambari-server/src/main/resources/common-services/YARN/2.1.0.2.0/package/scripts/mapreduce2_client.py
----------------------------------------------------------------------
diff --git a/ambari-server/src/main/resources/common-services/YARN/2.1.0.2.0/package/scripts/mapreduce2_client.py b/ambari-server/src/main/resources/common-services/YARN/2.1.0.2.0/package/scripts/mapreduce2_client.py
index efcb2da..234e931 100644
--- a/ambari-server/src/main/resources/common-services/YARN/2.1.0.2.0/package/scripts/mapreduce2_client.py
+++ b/ambari-server/src/main/resources/common-services/YARN/2.1.0.2.0/package/scripts/mapreduce2_client.py
@@ -24,7 +24,7 @@ import sys
# Local imports
from resource_management.libraries.script.script import Script
-from resource_management.libraries.functions import conf_select, stack_select
+from resource_management.libraries.functions import stack_select
from resource_management.libraries.functions.constants import StackFeature
from resource_management.libraries.functions.stack_features import check_stack_feature
from resource_management.core.exceptions import ClientComponentHasNoStatus
@@ -66,12 +66,9 @@ class MapReduce2Client(Script):
config_dir = self.get_config_dir_during_stack_upgrade(env, base_dir, conf_select_name)
if config_dir:
- Logger.info("stack_upgrade_save_new_config(): Calling conf-select on %s using version %s" % (conf_select_name, str(params.version)))
-
# Because this script was called from ru_execute_tasks.py which already enters an Environment with its own basedir,
# must change it now so this function can find the Jinja Templates for the service.
env.config.basedir = base_dir
- conf_select.select(params.stack_name, conf_select_name, params.version)
self.configure(env, config_dir=config_dir)
@@ -87,7 +84,6 @@ class MapReduce2ClientDefault(MapReduce2Client):
env.set_params(params)
if params.version and check_stack_feature(StackFeature.ROLLING_UPGRADE, params.version):
- conf_select.select(params.stack_name, "hadoop", params.version)
stack_select.select_packages(params.version)
http://git-wip-us.apache.org/repos/asf/ambari/blob/0535ca64/ambari-server/src/main/resources/common-services/YARN/2.1.0.2.0/package/scripts/nodemanager.py
----------------------------------------------------------------------
diff --git a/ambari-server/src/main/resources/common-services/YARN/2.1.0.2.0/package/scripts/nodemanager.py b/ambari-server/src/main/resources/common-services/YARN/2.1.0.2.0/package/scripts/nodemanager.py
index acd0991..a3a7455 100644
--- a/ambari-server/src/main/resources/common-services/YARN/2.1.0.2.0/package/scripts/nodemanager.py
+++ b/ambari-server/src/main/resources/common-services/YARN/2.1.0.2.0/package/scripts/nodemanager.py
@@ -22,7 +22,6 @@ Ambari Agent
import nodemanager_upgrade
from resource_management import *
-from resource_management.libraries.functions import conf_select
from resource_management.libraries.functions import stack_select
from resource_management.libraries.functions import StackFeature
from resource_management.libraries.functions.stack_features import check_stack_feature
@@ -71,7 +70,6 @@ class NodemanagerDefault(Nodemanager):
env.set_params(params)
if params.version and check_stack_feature(StackFeature.ROLLING_UPGRADE, params.version):
- conf_select.select(params.stack_name, "hadoop", params.version)
stack_select.select_packages(params.version)
def post_upgrade_restart(self, env, upgrade_type=None):
http://git-wip-us.apache.org/repos/asf/ambari/blob/0535ca64/ambari-server/src/main/resources/common-services/YARN/2.1.0.2.0/package/scripts/resourcemanager.py
----------------------------------------------------------------------
diff --git a/ambari-server/src/main/resources/common-services/YARN/2.1.0.2.0/package/scripts/resourcemanager.py b/ambari-server/src/main/resources/common-services/YARN/2.1.0.2.0/package/scripts/resourcemanager.py
index 2d74aa9..824482e 100644
--- a/ambari-server/src/main/resources/common-services/YARN/2.1.0.2.0/package/scripts/resourcemanager.py
+++ b/ambari-server/src/main/resources/common-services/YARN/2.1.0.2.0/package/scripts/resourcemanager.py
@@ -20,7 +20,6 @@ Ambari Agent
"""
from resource_management.libraries.script.script import Script
-from resource_management.libraries.functions import conf_select
from resource_management.libraries.functions import stack_select
from resource_management.libraries.functions import StackFeature
from resource_management.libraries.functions.stack_features import check_stack_feature
@@ -111,7 +110,6 @@ class ResourcemanagerDefault(Resourcemanager):
env.set_params(params)
if params.version and check_stack_feature(StackFeature.ROLLING_UPGRADE, params.version):
- conf_select.select(params.stack_name, "hadoop", params.version)
stack_select.select_packages(params.version)
def start(self, env, upgrade_type=None):
http://git-wip-us.apache.org/repos/asf/ambari/blob/0535ca64/ambari-server/src/main/resources/common-services/YARN/2.1.0.2.0/package/scripts/yarn_client.py
----------------------------------------------------------------------
diff --git a/ambari-server/src/main/resources/common-services/YARN/2.1.0.2.0/package/scripts/yarn_client.py b/ambari-server/src/main/resources/common-services/YARN/2.1.0.2.0/package/scripts/yarn_client.py
index d57060c..c1e52b7 100644
--- a/ambari-server/src/main/resources/common-services/YARN/2.1.0.2.0/package/scripts/yarn_client.py
+++ b/ambari-server/src/main/resources/common-services/YARN/2.1.0.2.0/package/scripts/yarn_client.py
@@ -21,7 +21,6 @@ Ambari Agent
import sys
from resource_management import *
-from resource_management.libraries.functions import conf_select
from resource_management.libraries.functions import stack_select
from resource_management.libraries.functions import StackFeature
from resource_management.libraries.functions.stack_features import check_stack_feature
@@ -56,7 +55,6 @@ class YarnClientDefault(YarnClient):
env.set_params(params)
if params.version and check_stack_feature(StackFeature.ROLLING_UPGRADE, params.version):
- conf_select.select(params.stack_name, "hadoop", params.version)
stack_select.select_packages(params.version)
http://git-wip-us.apache.org/repos/asf/ambari/blob/0535ca64/ambari-server/src/main/resources/common-services/ZEPPELIN/0.6.0.2.5/package/scripts/master.py
----------------------------------------------------------------------
diff --git a/ambari-server/src/main/resources/common-services/ZEPPELIN/0.6.0.2.5/package/scripts/master.py b/ambari-server/src/main/resources/common-services/ZEPPELIN/0.6.0.2.5/package/scripts/master.py
index f8f6e3d..7f506c5 100644
--- a/ambari-server/src/main/resources/common-services/ZEPPELIN/0.6.0.2.5/package/scripts/master.py
+++ b/ambari-server/src/main/resources/common-services/ZEPPELIN/0.6.0.2.5/package/scripts/master.py
@@ -30,7 +30,6 @@ from resource_management.core.source import StaticFile
from resource_management.libraries import XmlConfig
from resource_management.libraries.functions.check_process_status import check_process_status
from resource_management.libraries.functions.format import format
-from resource_management.libraries.functions import conf_select
from resource_management.libraries.functions import stack_select
from resource_management.libraries.functions import StackFeature
from resource_management.libraries.functions.decorator import retry
@@ -251,7 +250,6 @@ class Master(Script):
env.set_params(params)
if params.version and check_stack_feature(StackFeature.ROLLING_UPGRADE, format_stack_version(params.version)):
- conf_select.select(params.stack_name, "zeppelin", params.version)
stack_select.select_packages(params.version)
def set_interpreter_settings(self, config_data):
http://git-wip-us.apache.org/repos/asf/ambari/blob/0535ca64/ambari-server/src/main/resources/common-services/ZOOKEEPER/3.4.5/package/scripts/zookeeper_client.py
----------------------------------------------------------------------
diff --git a/ambari-server/src/main/resources/common-services/ZOOKEEPER/3.4.5/package/scripts/zookeeper_client.py b/ambari-server/src/main/resources/common-services/ZOOKEEPER/3.4.5/package/scripts/zookeeper_client.py
index 6c60e91..bca007b 100644
--- a/ambari-server/src/main/resources/common-services/ZOOKEEPER/3.4.5/package/scripts/zookeeper_client.py
+++ b/ambari-server/src/main/resources/common-services/ZOOKEEPER/3.4.5/package/scripts/zookeeper_client.py
@@ -21,7 +21,6 @@ Ambari Agent
import sys
from resource_management import *
-from resource_management.libraries.functions import conf_select
from resource_management.libraries.functions import stack_select
from resource_management.libraries.functions import StackFeature
from resource_management.libraries.functions.version import compare_versions, format_stack_version
@@ -66,7 +65,6 @@ class ZookeeperClientLinux(ZookeeperClient):
env.set_params(params)
if params.version and check_stack_feature(StackFeature.ROLLING_UPGRADE, format_stack_version(params.version)):
- conf_select.select(params.stack_name, "zookeeper", params.version)
stack_select.select_packages(params.version)
@OsFamilyImpl(os_family=OSConst.WINSRV_FAMILY)
http://git-wip-us.apache.org/repos/asf/ambari/blob/0535ca64/ambari-server/src/main/resources/common-services/ZOOKEEPER/3.4.5/package/scripts/zookeeper_server.py
----------------------------------------------------------------------
diff --git a/ambari-server/src/main/resources/common-services/ZOOKEEPER/3.4.5/package/scripts/zookeeper_server.py b/ambari-server/src/main/resources/common-services/ZOOKEEPER/3.4.5/package/scripts/zookeeper_server.py
index a42cfb6..641e82e 100644
--- a/ambari-server/src/main/resources/common-services/ZOOKEEPER/3.4.5/package/scripts/zookeeper_server.py
+++ b/ambari-server/src/main/resources/common-services/ZOOKEEPER/3.4.5/package/scripts/zookeeper_server.py
@@ -24,7 +24,6 @@ from ambari_commons.constants import UPGRADE_TYPE_NON_ROLLING
from resource_management.libraries.script.script import Script
from resource_management.libraries.functions import get_unique_id_and_date
-from resource_management.libraries.functions import conf_select
from resource_management.libraries.functions import stack_select
from resource_management.libraries.functions import StackFeature
from resource_management.libraries.functions.version import format_stack_version
@@ -74,7 +73,6 @@ class ZookeeperServerLinux(ZookeeperServer):
env.set_params(params)
if check_stack_feature(StackFeature.ROLLING_UPGRADE, format_stack_version(params.version)):
- conf_select.select(params.stack_name, "zookeeper", params.version)
stack_select.select_packages(params.version)
def post_upgrade_restart(self, env, upgrade_type=None):
http://git-wip-us.apache.org/repos/asf/ambari/blob/0535ca64/ambari-server/src/main/resources/custom_actions/scripts/install_packages.py
----------------------------------------------------------------------
diff --git a/ambari-server/src/main/resources/custom_actions/scripts/install_packages.py b/ambari-server/src/main/resources/custom_actions/scripts/install_packages.py
index c0b0e23..9c08bf9 100644
--- a/ambari-server/src/main/resources/custom_actions/scripts/install_packages.py
+++ b/ambari-server/src/main/resources/custom_actions/scripts/install_packages.py
@@ -206,10 +206,6 @@ class InstallPackages(Script):
Link("/usr/bin/conf-select", to = "/usr/bin/hdfconf-select")
for package_name, directories in conf_select.get_package_dirs().iteritems():
- conf_selector_name = stack_tools.get_stack_tool_name(stack_tools.CONF_SELECTOR_NAME)
- Logger.info("The current cluster stack of {0} does not require backing up configurations; "
- "only {1} versioned config directories will be created.".format(stack_version, conf_selector_name))
- # only link configs for all known packages
conf_select.select(self.stack_name, package_name, stack_version, ignore_errors = True)
http://git-wip-us.apache.org/repos/asf/ambari/blob/0535ca64/ambari-server/src/main/resources/custom_actions/scripts/ru_set_all.py
----------------------------------------------------------------------
diff --git a/ambari-server/src/main/resources/custom_actions/scripts/ru_set_all.py b/ambari-server/src/main/resources/custom_actions/scripts/ru_set_all.py
index e514c4b..665fb85 100644
--- a/ambari-server/src/main/resources/custom_actions/scripts/ru_set_all.py
+++ b/ambari-server/src/main/resources/custom_actions/scripts/ru_set_all.py
@@ -79,45 +79,6 @@ class UpgradeSetAll(Script):
link_config(dir_def['conf_dir'], dir_def['current_dir'])
- def unlink_all_configs(self, env):
- """
- Reverses the work performed in link_config. This should only be used when downgrading from
- HDP 2.3 to 2.2 in order to under the symlink work required for 2.3.
- """
- stack_name = default('/hostLevelParams/stack_name', "").upper()
- downgrade_to_version = default('/commandParams/version', None)
- downgrade_from_version = default('/commandParams/downgrade_from_version', None)
- upgrade_direction = default("/commandParams/upgrade_direction", Direction.UPGRADE)
-
- # downgrade only
- if upgrade_direction != Direction.DOWNGRADE:
- Logger.warning("Unlinking configurations should only be performed on a downgrade.")
- return
-
- if downgrade_to_version is None or downgrade_from_version is None:
- Logger.warning("Both 'commandParams/version' and 'commandParams/downgrade_from_version' must be specified to unlink configs on downgrade.")
- return
-
- Logger.info("Unlinking all configs when downgrading from {0} {1} to {2}".format(
- stack_name, downgrade_from_version, downgrade_to_version))
-
- # normalize the versions
- downgrade_to_version = format_stack_version(downgrade_to_version)
- downgrade_from_version = format_stack_version(downgrade_from_version)
-
- # downgrade-to-version must be 2.2 (less than 2.3)
- if downgrade_to_version and check_stack_feature(StackFeature.CONFIG_VERSIONING, downgrade_to_version):
- Logger.warning("Unlinking configurations should not be performed when downgrading {0} {1} to {2}".format(
- stack_name, downgrade_from_version, downgrade_to_version))
- return
-
- # downgrade-from-version must be 2.3+
- if not( downgrade_from_version and check_stack_feature(StackFeature.CONFIG_VERSIONING, downgrade_from_version) ):
- Logger.warning("Unlinking configurations should not be performed when downgrading {0} {1} to {2}".format(
- stack_name, downgrade_from_version, downgrade_to_version))
- return
-
-
def is_host_skippable(stack_selector_path, formatted_version):
"""
Gets whether this host should not have the stack select tool called.
http://git-wip-us.apache.org/repos/asf/ambari/blob/0535ca64/ambari-server/src/main/resources/stacks/BigInsights/4.0/configuration/cluster-env.xml
----------------------------------------------------------------------
diff --git a/ambari-server/src/main/resources/stacks/BigInsights/4.0/configuration/cluster-env.xml b/ambari-server/src/main/resources/stacks/BigInsights/4.0/configuration/cluster-env.xml
index c73b6e4..21a180e 100755
--- a/ambari-server/src/main/resources/stacks/BigInsights/4.0/configuration/cluster-env.xml
+++ b/ambari-server/src/main/resources/stacks/BigInsights/4.0/configuration/cluster-env.xml
@@ -299,6 +299,21 @@ gpgcheck=0</value>
</value-attributes>
<on-ambari-upgrade add="true"/>
</property>
+ <!-- Define stack_packages property in the base stack. DO NOT override this property for each stack version -->
+ <property>
+ <name>stack_packages</name>
+ <value/>
+ <description>Associations between component and stack-select tools.</description>
+ <property-type>VALUE_FROM_PROPERTY_FILE</property-type>
+ <value-attributes>
+ <property-file-name>stack_packages.json</property-file-name>
+ <property-file-type>json</property-file-type>
+ <read-only>true</read-only>
+ <overridable>false</overridable>
+ <visible>false</visible>
+ </value-attributes>
+ <on-ambari-upgrade add="true"/>
+ </property>
<property>
<name>stack_root</name>
<value>{"BigInsights":"/usr/iop"}</value>
http://git-wip-us.apache.org/repos/asf/ambari/blob/0535ca64/ambari-server/src/main/resources/stacks/BigInsights/4.0/properties/stack_packages.json
----------------------------------------------------------------------
diff --git a/ambari-server/src/main/resources/stacks/BigInsights/4.0/properties/stack_packages.json b/ambari-server/src/main/resources/stacks/BigInsights/4.0/properties/stack_packages.json
new file mode 100644
index 0000000..930b4ca
--- /dev/null
+++ b/ambari-server/src/main/resources/stacks/BigInsights/4.0/properties/stack_packages.json
@@ -0,0 +1,969 @@
+{
+ "BigInsights": {
+ "stack-select": {
+ "ATLAS": {
+ "ATLAS_CLIENT": {
+ "STACK-SELECT-PACKAGE": "atlas-client",
+ "INSTALL": [
+ "atlas-client"
+ ],
+ "PATCH": [
+ "atlas-client"
+ ],
+ "STANDARD": [
+ "atlas-client"
+ ]
+ },
+ "ATLAS_SERVER": {
+ "STACK-SELECT-PACKAGE": "atlas-server",
+ "INSTALL": [
+ "atlas-server"
+ ],
+ "PATCH": [
+ "atlas-server"
+ ],
+ "STANDARD": [
+ "atlas-server"
+ ]
+ }
+ },
+ "FLUME": {
+ "FLUME_HANDLER": {
+ "STACK-SELECT-PACKAGE": "flume-server",
+ "INSTALL": [
+ "flume-server"
+ ],
+ "PATCH": [
+ "flume-server"
+ ],
+ "STANDARD": [
+ "flume-server"
+ ]
+ }
+ },
+ "HBASE": {
+ "HBASE_CLIENT": {
+ "STACK-SELECT-PACKAGE": "hbase-client",
+ "INSTALL": [
+ "hbase-client",
+ "hadoop-client"
+ ],
+ "PATCH": [
+ "hbase-client"
+ ],
+ "STANDARD": [
+ "hbase-client",
+ "hadoop-client"
+ ]
+ },
+ "HBASE_MASTER": {
+ "STACK-SELECT-PACKAGE": "hbase-master",
+ "INSTALL": [
+ "hbase-master"
+ ],
+ "PATCH": [
+ "hbase-master"
+ ],
+ "STANDARD": [
+ "hbase-master"
+ ]
+ },
+ "HBASE_REGIONSERVER": {
+ "STACK-SELECT-PACKAGE": "hbase-regionserver",
+ "INSTALL": [
+ "hbase-regionserver"
+ ],
+ "PATCH": [
+ "hbase-regionserver"
+ ],
+ "STANDARD": [
+ "hbase-regionserver"
+ ]
+ },
+ "HBASE_REST_SERVER": {
+ "STACK-SELECT-PACKAGE": "hbase-restserver",
+ "INSTALL": [
+ "hbase-restserver"
+ ],
+ "PATCH": [
+ "hbase-restserver"
+ ],
+ "STANDARD": [
+ "hbase-restserver"
+ ]
+ },
+
+ "PHOENIX_QUERY_SERVER": {
+ "STACK-SELECT-PACKAGE": "phoenix-server",
+ "INSTALL": [
+ "phoenix-server"
+ ],
+ "PATCH": [
+ "phoenix-server"
+ ],
+ "STANDARD": [
+ "phoenix-server"
+ ]
+ }
+ },
+ "HDFS": {
+ "DATANODE": {
+ "STACK-SELECT-PACKAGE": "hadoop-hdfs-datanode",
+ "INSTALL": [
+ "hadoop-hdfs-datanode"
+ ],
+ "PATCH": [
+ "hadoop-hdfs-datanode"
+ ],
+ "STANDARD": [
+ "hadoop-hdfs-datanode"
+ ]
+ },
+ "HDFS_CLIENT": {
+ "STACK-SELECT-PACKAGE": "hadoop-client",
+ "INSTALL": [
+ "hadoop-client"
+ ],
+ "PATCH": [
+ "hadoop-client"
+ ],
+ "STANDARD": [
+ "hadoop-client"
+ ]
+ },
+ "NAMENODE": {
+ "STACK-SELECT-PACKAGE": "hadoop-hdfs-namenode",
+ "INSTALL": [
+ "hadoop-hdfs-namenode"
+ ],
+ "PATCH": [
+ "hadoop-hdfs-namenode"
+ ],
+ "STANDARD": [
+ "hadoop-hdfs-namenode"
+ ]
+ },
+ "NFS_GATEWAY": {
+ "STACK-SELECT-PACKAGE": "hadoop-hdfs-nfs3",
+ "INSTALL": [
+ "hadoop-hdfs-nfs3"
+ ],
+ "PATCH": [
+ "hadoop-hdfs-nfs3"
+ ],
+ "STANDARD": [
+ "hadoop-hdfs-nfs3"
+ ]
+ },
+ "JOURNALNODE": {
+ "STACK-SELECT-PACKAGE": "hadoop-hdfs-journalnode",
+ "INSTALL": [
+ "hadoop-hdfs-journalnode"
+ ],
+ "PATCH": [
+ "hadoop-hdfs-journalnode"
+ ],
+ "STANDARD": [
+ "hadoop-hdfs-journalnode"
+ ]
+ },
+ "SECONDARY_NAMENODE": {
+ "STACK-SELECT-PACKAGE": "hadoop-hdfs-secondarynamenode",
+ "INSTALL": [
+ "hadoop-hdfs-secondarynamenode"
+ ],
+ "PATCH": [
+ "hadoop-hdfs-secondarynamenode"
+ ],
+ "STANDARD": [
+ "hadoop-hdfs-secondarynamenode"
+ ]
+ },
+ "ZKFC": {
+ "STACK-SELECT-PACKAGE": "hadoop-hdfs-zkfc",
+ "INSTALL": [
+ "hadoop-hdfs-zkfc"
+ ],
+ "PATCH": [
+ "hadoop-hdfs-zkfc"
+ ],
+ "STANDARD": [
+ "hadoop-hdfs-zkfc"
+ ]
+ }
+ },
+ "HIVE": {
+ "HCAT": {
+ "STACK-SELECT-PACKAGE": "hive-webhcat",
+ "INSTALL": [
+ "hive-webhcat"
+ ],
+ "PATCH": [
+ "hive-webhcat"
+ ],
+ "STANDARD": [
+ "hive-webhcat"
+ ]
+ },
+ "HIVE_METASTORE": {
+ "STACK-SELECT-PACKAGE": "hive-metastore",
+ "INSTALL": [
+ "hive-metastore"
+ ],
+ "PATCH": [
+ "hive-metastore"
+ ],
+ "STANDARD": [
+ "hive-metastore"
+ ]
+ },
+ "HIVE_SERVER": {
+ "STACK-SELECT-PACKAGE": "hive-server2",
+ "INSTALL": [
+ "hive-server2"
+ ],
+ "PATCH": [
+ "hive-server2"
+ ],
+ "STANDARD": [
+ "hive-server2"
+ ]
+ },
+ "HIVE_SERVER_INTERACTIVE": {
+ "STACK-SELECT-PACKAGE": "hive-server2-hive2",
+ "INSTALL": [
+ "hive-server2-hive2"
+ ],
+ "PATCH": [
+ "hive-server2-hive2"
+ ],
+ "STANDARD": [
+ "hive-server2-hive2"
+ ]
+ },
+ "HIVE_CLIENT": {
+ "STACK-SELECT-PACKAGE": "hadoop-client",
+ "INSTALL": [
+ "hadoop-client"
+ ],
+ "PATCH": [
+ "hadoop-client"
+ ],
+ "STANDARD": [
+ "hadoop-client"
+ ]
+ },
+ "WEBHCAT_SERVER": {
+ "STACK-SELECT-PACKAGE": "hive-webhcat",
+ "INSTALL": [
+ "hive-webhcat"
+ ],
+ "PATCH": [
+ "hive-webhcat"
+ ],
+ "STANDARD": [
+ "hive-webhcat"
+ ]
+ }
+ },
+ "KAFKA": {
+ "KAFKA_BROKER": {
+ "STACK-SELECT-PACKAGE": "kafka-broker",
+ "INSTALL": [
+ "kafka-broker"
+ ],
+ "PATCH": [
+ "kafka-broker"
+ ],
+ "STANDARD": [
+ "kafka-broker"
+ ]
+ }
+ },
+ "KNOX": {
+ "KNOX_GATEWAY": {
+ "STACK-SELECT-PACKAGE": "knox-server",
+ "INSTALL": [
+ "knox-server"
+ ],
+ "PATCH": [
+ "knox-server"
+ ],
+ "STANDARD": [
+ "knox-server"
+ ]
+ }
+ },
+ "MAPREDUCE2": {
+ "HISTORYSERVER": {
+ "STACK-SELECT-PACKAGE": "hadoop-mapreduce-historyserver",
+ "INSTALL": [
+ "hadoop-mapreduce-historyserver"
+ ],
+ "PATCH": [
+ "hadoop-mapreduce-historyserver"
+ ],
+ "STANDARD": [
+ "hadoop-mapreduce-historyserver"
+ ]
+ },
+ "MAPREDUCE2_CLIENT": {
+ "STACK-SELECT-PACKAGE": "hadoop-client",
+ "INSTALL": [
+ "hadoop-client"
+ ],
+ "PATCH": [
+ "hadoop-client"
+ ],
+ "STANDARD": [
+ "hadoop-client"
+ ]
+ }
+ },
+ "OOZIE": {
+ "OOZIE_CLIENT": {
+ "STACK-SELECT-PACKAGE": "oozie-client",
+ "INSTALL": [
+ "oozie-client"
+ ],
+ "PATCH": [
+ "oozie-client"
+ ],
+ "STANDARD": [
+ "oozie-client"
+ ]
+ },
+ "OOZIE_SERVER": {
+ "STACK-SELECT-PACKAGE": "oozie-server",
+ "INSTALL": [
+ "oozie-client",
+ "oozie-server"
+ ],
+ "PATCH": [
+ "oozie-server"
+ ],
+ "STANDARD": [
+ "oozie-client",
+ "oozie-server"
+ ]
+ }
+ },
+ "PIG": {
+ "PIG": {
+ "STACK-SELECT-PACKAGE": "hadoop-client",
+ "INSTALL": [
+ "hadoop-client"
+ ],
+ "PATCH": [
+ "hadoop-client"
+ ],
+ "STANDARD": [
+ "hadoop-client"
+ ]
+ }
+ },
+ "R4ML": {
+ "R4ML": {
+ "STACK-SELECT-PACKAGE": "r4ml-client",
+ "INSTALL": [
+ "r4ml-client"
+ ],
+ "PATCH": [
+ "r4ml-client"
+ ],
+ "STANDARD": [
+ "r4ml-client"
+ ]
+ }
+ },
+ "RANGER": {
+ "RANGER_ADMIN": {
+ "STACK-SELECT-PACKAGE": "ranger-admin",
+ "INSTALL": [
+ "ranger-admin"
+ ],
+ "PATCH": [
+ "ranger-admin"
+ ],
+ "STANDARD": [
+ "ranger-admin"
+ ]
+ },
+ "RANGER_TAGSYNC": {
+ "STACK-SELECT-PACKAGE": "ranger-tagsync",
+ "INSTALL": [
+ "ranger-tagsync"
+ ],
+ "PATCH": [
+ "ranger-tagsync"
+ ],
+ "STANDARD": [
+ "ranger-tagsync"
+ ]
+ },
+ "RANGER_USERSYNC": {
+ "STACK-SELECT-PACKAGE": "ranger-usersync",
+ "INSTALL": [
+ "ranger-usersync"
+ ],
+ "PATCH": [
+ "ranger-usersync"
+ ],
+ "STANDARD": [
+ "ranger-usersync"
+ ]
+ }
+ },
+ "RANGER_KMS": {
+ "RANGER_KMS_SERVER": {
+ "STACK-SELECT-PACKAGE": "ranger-kms",
+ "INSTALL": [
+ "ranger-kms"
+ ],
+ "PATCH": [
+ "ranger-kms"
+ ],
+ "STANDARD": [
+ "ranger-kms"
+ ]
+ }
+ },
+ "SLIDER": {
+ "SLIDER": {
+ "STACK-SELECT-PACKAGE": "slider-client",
+ "INSTALL": [
+ "slider-client",
+ "hadoop-client"
+ ],
+ "PATCH": [
+ "slider-client"
+ ],
+ "STANDARD": [
+ "slider-client",
+ "hadoop-client"
+ ]
+ }
+ },
+ "SOLR": {
+ "SOLR": {
+ "STACK-SELECT-PACKAGE": "solr-server",
+ "INSTALL": [
+ "solr-server"
+ ],
+ "PATCH": [
+ "solr-server"
+ ],
+ "STANDARD": [
+ "solr-server"
+ ]
+ }
+ },
+ "SPARK": {
+ "LIVY_SERVER": {
+ "STACK-SELECT-PACKAGE": "livy-server",
+ "INSTALL": [
+ "livy-server"
+ ],
+ "PATCH": [
+ "livy-server"
+ ],
+ "STANDARD": [
+ "livy-server"
+ ]
+ },
+ "SPARK_CLIENT": {
+ "STACK-SELECT-PACKAGE": "spark-client",
+ "INSTALL": [
+ "spark-client"
+ ],
+ "PATCH": [
+ "spark-client"
+ ],
+ "STANDARD": [
+ "spark-client"
+ ]
+ },
+ "SPARK_JOBHISTORYSERVER": {
+ "STACK-SELECT-PACKAGE": "spark-historyserver",
+ "INSTALL": [
+ "spark-historyserver"
+ ],
+ "PATCH": [
+ "spark-historyserver"
+ ],
+ "STANDARD": [
+ "spark-historyserver"
+ ]
+ },
+ "SPARK_THRIFTSERVER": {
+ "STACK-SELECT-PACKAGE": "spark-thriftserver",
+ "INSTALL": [
+ "spark-thriftserver"
+ ],
+ "PATCH": [
+ "spark-thriftserver"
+ ],
+ "STANDARD": [
+ "spark-thriftserver"
+ ]
+ }
+ },
+ "SPARK2": {
+ "LIVY2_SERVER": {
+ "STACK-SELECT-PACKAGE": "livy2-server",
+ "INSTALL": [
+ "livy2-server"
+ ],
+ "PATCH": [
+ "livy2-server"
+ ],
+ "STANDARD": [
+ "livy2-server"
+ ]
+ },
+ "SPARK2_CLIENT": {
+ "STACK-SELECT-PACKAGE": "spark2-client",
+ "INSTALL": [
+ "spark2-client"
+ ],
+ "PATCH": [
+ "spark2-client"
+ ],
+ "STANDARD": [
+ "spark2-client"
+ ]
+ },
+ "SPARK2_JOBHISTORYSERVER": {
+ "STACK-SELECT-PACKAGE": "spark2-historyserver",
+ "INSTALL": [
+ "spark2-historyserver"
+ ],
+ "PATCH": [
+ "spark2-historyserver"
+ ],
+ "STANDARD": [
+ "spark2-historyserver"
+ ]
+ },
+ "SPARK2_THRIFTSERVER": {
+ "STACK-SELECT-PACKAGE": "spark2-thriftserver",
+ "INSTALL": [
+ "spark2-thriftserver"
+ ],
+ "PATCH": [
+ "spark2-thriftserver"
+ ],
+ "STANDARD": [
+ "spark2-thriftserver"
+ ]
+ }
+ },
+ "SQOOP": {
+ "SQOOP": {
+ "STACK-SELECT-PACKAGE": "sqoop-client",
+ "INSTALL": [
+ "sqoop-client"
+ ],
+ "PATCH": [
+ "sqoop-client"
+ ],
+ "STANDARD": [
+ "sqoop-client"
+ ]
+ }
+ },
+ "STORM": {
+ "NIMBUS": {
+ "STACK-SELECT-PACKAGE": "storm-nimbus",
+ "INSTALL": [
+ "storm-client",
+ "storm-nimbus"
+ ],
+ "PATCH": [
+ "storm-client",
+ "storm-nimbus"
+ ],
+ "STANDARD": [
+ "storm-client",
+ "storm-nimbus"
+ ]
+ },
+ "SUPERVISOR": {
+ "STACK-SELECT-PACKAGE": "storm-supervisor",
+ "INSTALL": [
+ "storm-supervisor"
+ ],
+ "PATCH": [
+ "storm-supervisor"
+ ],
+ "STANDARD": [
+ "storm-client",
+ "storm-supervisor"
+ ]
+ },
+ "DRPC_SERVER": {
+ "STACK-SELECT-PACKAGE": "storm-client",
+ "INSTALL": [
+ "storm-client"
+ ],
+ "PATCH": [
+ "storm-client"
+ ],
+ "STANDARD": [
+ "storm-client"
+ ]
+ },
+ "STORM_UI_SERVER": {
+ "STACK-SELECT-PACKAGE": "storm-client",
+ "INSTALL": [
+ "storm-client"
+ ],
+ "PATCH": [
+ "storm-client"
+ ],
+ "STANDARD": [
+ "storm-client"
+ ]
+ }
+ },
+ "SYSTEMML": {
+ "SYSTEMML": {
+ "STACK-SELECT-PACKAGE": "systemml-client",
+ "INSTALL": [
+ "systemml-client"
+ ],
+ "PATCH": [
+ "systemml-client"
+ ],
+ "STANDARD": [
+ "systemml-client"
+ ]
+ }
+ },
+ "TEZ": {
+ "TEZ_CLIENT": {
+ "STACK-SELECT-PACKAGE": "hadoop-client",
+ "INSTALL": [
+ "hadoop-client"
+ ],
+ "PATCH": [
+ "hadoop-client"
+ ],
+ "STANDARD": [
+ "hadoop-client"
+ ]
+ }
+ },
+ "TITAN": {
+ "TITAN_CLIENT": {
+ "STACK-SELECT-PACKAGE": "titan-client",
+ "INSTALL": [
+ "titan-client"
+ ],
+ "PATCH": [
+ "titan-client"
+ ],
+ "STANDARD": [
+ "titan-client"
+ ]
+ },
+ "TITAN_SERVER": {
+ "STACK-SELECT-PACKAGE": "titan-server",
+ "INSTALL": [
+ "titan-server"
+ ],
+ "PATCH": [
+ "titan-server"
+ ],
+ "STANDARD": [
+ "titan-server"
+ ]
+ }
+ },
+ "YARN": {
+ "APP_TIMELINE_SERVER": {
+ "STACK-SELECT-PACKAGE": "hadoop-yarn-timelineserver",
+ "INSTALL": [
+ "hadoop-yarn-timelineserver"
+ ],
+ "PATCH": [
+ "hadoop-yarn-timelineserver"
+ ],
+ "STANDARD": [
+ "hadoop-yarn-timelineserver"
+ ]
+ },
+ "NODEMANAGER": {
+ "STACK-SELECT-PACKAGE": "hadoop-yarn-nodemanager",
+ "INSTALL": [
+ "hadoop-yarn-nodemanager"
+ ],
+ "PATCH": [
+ "hadoop-yarn-nodemanager"
+ ],
+ "STANDARD": [
+ "hadoop-yarn-nodemanager"
+ ]
+ },
+ "RESOURCEMANAGER": {
+ "STACK-SELECT-PACKAGE": "hadoop-yarn-resourcemanager",
+ "INSTALL": [
+ "hadoop-yarn-resourcemanager"
+ ],
+ "PATCH": [
+ "hadoop-yarn-resourcemanager"
+ ],
+ "STANDARD": [
+ "hadoop-yarn-resourcemanager"
+ ]
+ },
+ "YARN_CLIENT": {
+ "STACK-SELECT-PACKAGE": "hadoop-client",
+ "INSTALL": [
+ "hadoop-client"
+ ],
+ "PATCH": [
+ "hadoop-client"
+ ],
+ "STANDARD": [
+ "hadoop-client"
+ ]
+ }
+ },
+ "ZEPPELIN": {
+ "ZEPPELIN_MASTER": {
+ "STACK-SELECT-PACKAGE": "zeppelin-server",
+ "INSTALL": [
+ "zeppelin-server"
+ ],
+ "PATCH": [
+ "zeppelin-server"
+ ],
+ "STANDARD": [
+ "zeppelin-server"
+ ]
+ }
+ },
+ "ZOOKEEPER": {
+ "ZOOKEEPER_CLIENT": {
+ "STACK-SELECT-PACKAGE": "zookeeper-client",
+ "INSTALL": [
+ "zookeeper-client"
+ ],
+ "PATCH": [
+ "zookeeper-client"
+ ],
+ "STANDARD": [
+ "zookeeper-client"
+ ]
+ },
+ "ZOOKEEPER_SERVER": {
+ "STACK-SELECT-PACKAGE": "zookeeper-server",
+ "INSTALL": [
+ "zookeeper-server"
+ ],
+ "PATCH": [
+ "zookeeper-server"
+ ],
+ "STANDARD": [
+ "zookeeper-server"
+ ]
+ }
+ }
+ },
+ "conf-select": {
+ "accumulo": [
+ {
+ "conf_dir": "/etc/accumulo/conf",
+ "current_dir": "{0}/current/accumulo-client/conf"
+ }
+ ],
+ "atlas": [
+ {
+ "conf_dir": "/etc/atlas/conf",
+ "current_dir": "{0}/current/atlas-client/conf"
+ }
+ ],
+ "druid": [
+ {
+ "conf_dir": "/etc/druid/conf",
+ "current_dir": "{0}/current/druid-overlord/conf"
+ }
+ ],
+ "falcon": [
+ {
+ "conf_dir": "/etc/falcon/conf",
+ "current_dir": "{0}/current/falcon-client/conf"
+ }
+ ],
+ "flume": [
+ {
+ "conf_dir": "/etc/flume/conf",
+ "current_dir": "{0}/current/flume-server/conf"
+ }
+ ],
+ "hadoop": [
+ {
+ "conf_dir": "/etc/hadoop/conf",
+ "current_dir": "{0}/current/hadoop-client/conf"
+ }
+ ],
+ "hbase": [
+ {
+ "conf_dir": "/etc/hbase/conf",
+ "current_dir": "{0}/current/hbase-client/conf"
+ }
+ ],
+ "hive": [
+ {
+ "conf_dir": "/etc/hive/conf",
+ "current_dir": "{0}/current/hive-client/conf"
+ }
+ ],
+ "hive2": [
+ {
+ "conf_dir": "/etc/hive2/conf",
+ "current_dir": "{0}/current/hive-server2-hive2/conf"
+ }
+ ],
+ "hive-hcatalog": [
+ {
+ "conf_dir": "/etc/hive-webhcat/conf",
+ "prefix": "/etc/hive-webhcat",
+ "current_dir": "{0}/current/hive-webhcat/etc/webhcat"
+ },
+ {
+ "conf_dir": "/etc/hive-hcatalog/conf",
+ "prefix": "/etc/hive-hcatalog",
+ "current_dir": "{0}/current/hive-webhcat/etc/hcatalog"
+ }
+ ],
+ "kafka": [
+ {
+ "conf_dir": "/etc/kafka/conf",
+ "current_dir": "{0}/current/kafka-broker/conf"
+ }
+ ],
+ "knox": [
+ {
+ "conf_dir": "/etc/knox/conf",
+ "current_dir": "{0}/current/knox-server/conf"
+ }
+ ],
+ "mahout": [
+ {
+ "conf_dir": "/etc/mahout/conf",
+ "current_dir": "{0}/current/mahout-client/conf"
+ }
+ ],
+ "nifi": [
+ {
+ "conf_dir": "/etc/nifi/conf",
+ "current_dir": "{0}/current/nifi/conf"
+ }
+ ],
+ "oozie": [
+ {
+ "conf_dir": "/etc/oozie/conf",
+ "current_dir": "{0}/current/oozie-client/conf"
+ }
+ ],
+ "phoenix": [
+ {
+ "conf_dir": "/etc/phoenix/conf",
+ "current_dir": "{0}/current/phoenix-client/conf"
+ }
+ ],
+ "pig": [
+ {
+ "conf_dir": "/etc/pig/conf",
+ "current_dir": "{0}/current/pig-client/conf"
+ }
+ ],
+ "ranger-admin": [
+ {
+ "conf_dir": "/etc/ranger/admin/conf",
+ "current_dir": "{0}/current/ranger-admin/conf"
+ }
+ ],
+ "ranger-kms": [
+ {
+ "conf_dir": "/etc/ranger/kms/conf",
+ "current_dir": "{0}/current/ranger-kms/conf"
+ }
+ ],
+ "ranger-tagsync": [
+ {
+ "conf_dir": "/etc/ranger/tagsync/conf",
+ "current_dir": "{0}/current/ranger-tagsync/conf"
+ }
+ ],
+ "ranger-usersync": [
+ {
+ "conf_dir": "/etc/ranger/usersync/conf",
+ "current_dir": "{0}/current/ranger-usersync/conf"
+ }
+ ],
+ "slider": [
+ {
+ "conf_dir": "/etc/slider/conf",
+ "current_dir": "{0}/current/slider-client/conf"
+ }
+ ],
+ "spark": [
+ {
+ "conf_dir": "/etc/spark/conf",
+ "current_dir": "{0}/current/spark-client/conf"
+ }
+ ],
+ "spark2": [
+ {
+ "conf_dir": "/etc/spark2/conf",
+ "current_dir": "{0}/current/spark2-client/conf"
+ }
+ ],
+ "sqoop": [
+ {
+ "conf_dir": "/etc/sqoop/conf",
+ "current_dir": "{0}/current/sqoop-client/conf"
+ }
+ ],
+ "storm": [
+ {
+ "conf_dir": "/etc/storm/conf",
+ "current_dir": "{0}/current/storm-client/conf"
+ }
+ ],
+ "storm-slider-client": [
+ {
+ "conf_dir": "/etc/storm-slider-client/conf",
+ "current_dir": "{0}/current/storm-slider-client/conf"
+ }
+ ],
+ "superset": [
+ {
+ "conf_dir": "/etc/druid-superset/conf",
+ "current_dir": "{0}/current/druid-superset/conf"
+ }
+ ],
+ "tez": [
+ {
+ "conf_dir": "/etc/tez/conf",
+ "current_dir": "{0}/current/tez-client/conf"
+ }
+ ],
+ "zeppelin": [
+ {
+ "conf_dir": "/etc/zeppelin/conf",
+ "current_dir": "{0}/current/zeppelin-server/conf"
+ }
+ ],
+ "zookeeper": [
+ {
+ "conf_dir": "/etc/zookeeper/conf",
+ "current_dir": "{0}/current/zookeeper-client/conf"
+ }
+ ]
+ }
+ }
+}