This is an automated email from the ASF dual-hosted git repository.
JiaLiangC pushed a commit to branch trunk
in repository https://gitbox.apache.org/repos/asf/ambari.git
The following commit(s) were added to refs/heads/trunk by this push:
new 57aa1b4d2d AMBARI-26598: Don't execute dangerous metatool command when
starting hiveserver2 (#4127)
57aa1b4d2d is described below
commit 57aa1b4d2d9ba15ad411a1853b7217022bcf7560
Author: Yubi Lee <[email protected]>
AuthorDate: Wed Jun 10 11:14:07 2026 +0900
AMBARI-26598: Don't execute dangerous metatool command when starting
hiveserver2 (#4127)
---
.../services/HIVE/package/scripts/hive_service.py | 25 ----------------------
1 file changed, 25 deletions(-)
diff --git
a/ambari-server/src/main/resources/stacks/BIGTOP/3.2.0/services/HIVE/package/scripts/hive_service.py
b/ambari-server/src/main/resources/stacks/BIGTOP/3.2.0/services/HIVE/package/scripts/hive_service.py
index 34cdbc4cf4..1ee2b95a2c 100644
---
a/ambari-server/src/main/resources/stacks/BIGTOP/3.2.0/services/HIVE/package/scripts/hive_service.py
+++
b/ambari-server/src/main/resources/stacks/BIGTOP/3.2.0/services/HIVE/package/scripts/hive_service.py
@@ -29,7 +29,6 @@ from resource_management.core import utils
from resource_management.core.exceptions import ComponentIsNotRunning, Fail
from resource_management.core.logger import Logger
from resource_management.core.resources.system import File, Execute
-from resource_management.core.shell import as_user, quote_bash_args
from resource_management.libraries.functions import get_user_call_output
from resource_management.libraries.functions import StackFeature
from resource_management.libraries.functions.check_process_status import (
@@ -70,9 +69,6 @@ def hive_service(name, action="start", upgrade_type=None):
)
if action == "start":
- if name == "hiveserver2":
- check_fs_root(params.hive_conf_dir, params.execute_path)
-
daemon_cmd = cmd
hadoop_home = params.hadoop_home
hive_bin = "hive"
@@ -189,27 +185,6 @@ def validate_connection(target_path_to_jdbc,
hive_lib_path):
raise
-def check_fs_root(conf_dir, execution_path):
- import params
-
- if not params.fs_root.startswith("hdfs://"):
- Logger.info("Skipping fs root check as fs_root does not start with
hdfs://")
- return
-
- metatool_cmd = format("hive --config {conf_dir} --service metatool")
- cmd = as_user(
- format("{metatool_cmd} -listFSRoot", env={"PATH": execution_path}),
params.hive_user
- ) + format(
- " 2>/dev/null | grep hdfs:// | cut -f1,2,3 -d '/' | grep -v '{fs_root}' |
head -1"
- )
- code, out = shell.call(cmd)
-
- if code == 0 and out.strip() != "" and params.fs_root.strip() != out.strip():
- out = out.strip()
- cmd = format("{metatool_cmd} -updateLocation {fs_root} {out}")
- Execute(cmd, user=params.hive_user, environment={"PATH": execution_path})
-
-
@retry(times=30, sleep_time=10, err_class=Fail)
def wait_for_znode():
import params
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
