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