|
@@ -23,20 +23,26 @@ from resource_management.libraries.script.script import Script
|
|
|
from resource_management.libraries.functions.format import format
|
|
|
from resource_management.libraries.functions.default import default
|
|
|
from resource_management.libraries.functions import get_kinit_path
|
|
|
+from resource_management.libraries.functions import StackFeature
|
|
|
+from resource_management.libraries.functions.stack_features import check_stack_feature
|
|
|
+from resource_management.libraries.functions.version import format_stack_version
|
|
|
from resource_management.libraries.functions.get_not_managed_resources import get_not_managed_resources
|
|
|
|
|
|
# server configurations
|
|
|
config = Script.get_config()
|
|
|
+stack_root = Script.get_stack_root()
|
|
|
|
|
|
-slider_home_dir = '/usr/hdp/current/slider-client'
|
|
|
+slider_home_dir = format('{stack_root}/current/slider-client')
|
|
|
+stack_version_unformatted = str(config['hostLevelParams']['stack_version'])
|
|
|
+stack_version_formatted = format_stack_version(stack_version_unformatted)
|
|
|
|
|
|
#hadoop params
|
|
|
slider_bin_dir = "/usr/lib/slider/bin"
|
|
|
-if Script.is_stack_greater_or_equal("2.2"):
|
|
|
+if stack_version_formatted and check_stack_feature(StackFeature.ROLLING_UPGRADE, stack_version_formatted):
|
|
|
slider_bin_dir = format('{slider_home_dir}/bin')
|
|
|
|
|
|
slider_conf_dir = format("{slider_home_dir}/conf")
|
|
|
-storm_slider_conf_dir = '/usr/hdp/current/storm-slider-client/conf'
|
|
|
+storm_slider_conf_dir = format('{stack_root}/current/storm-slider-client/conf')
|
|
|
|
|
|
slider_lib_dir = format('{slider_home_dir}/lib')
|
|
|
slider_tar_gz = format('{slider_lib_dir}/slider.tar.gz')
|