From c27f3e3f7cba4dd729101afcac095576d4469b69 Mon Sep 17 00:00:00 2001 From: Murali Krishna Date: Mon, 21 Aug 2023 08:48:49 +0530 Subject: [PATCH] AMBARI-25956: [ Rolling upgrade] Hive Server Going down after upgrade --- .../services/HIVE/package/scripts/hive_server_upgrade.py | 5 ++++- 1 file changed, 4 insertions(+), 1 deletion(-) diff --git a/ambari-server/src/main/resources/stacks/BIGTOP/3.2.0/services/HIVE/package/scripts/hive_server_upgrade.py b/ambari-server/src/main/resources/stacks/BIGTOP/3.2.0/services/HIVE/package/scripts/hive_server_upgrade.py index 7560ceeaab1..ff74de1f18a 100644 --- a/ambari-server/src/main/resources/stacks/BIGTOP/3.2.0/services/HIVE/package/scripts/hive_server_upgrade.py +++ b/ambari-server/src/main/resources/stacks/BIGTOP/3.2.0/services/HIVE/package/scripts/hive_server_upgrade.py @@ -29,6 +29,7 @@ from resource_management.libraries.functions import format from resource_management.libraries.functions import stack_select from resource_management.libraries.functions import StackFeature +from resource_management.libraries.functions import upgrade_summary from resource_management.libraries.functions.stack_features import check_stack_feature from resource_management.libraries.functions.version import format_stack_version @@ -113,9 +114,11 @@ def _get_current_hiveserver_version(): try: # When downgrading the source version should be the version we are downgrading from - source_version = params.version_for_stack_feature_checks if params.downgrade_from_version is not None: source_version = params.downgrade_from_version + else: + source_version = upgrade_summary.get_source_version("HIVE", + default_version = params.version_for_stack_feature_checks) hive_execute_path = _get_hive_execute_path(source_version) version_hive_bin = params.hive_bin_dir