|
@@ -93,7 +93,7 @@ def namenode(action=None, do_format=True, rolling_restart=False, env=None):
|
|
|
|
|
|
if leave_safe_mode:
|
|
|
# First check if Namenode is not in 'safemode OFF' (equivalent to safemode ON), if so, then leave it
|
|
|
- code, out = shell.call(namenode_safe_mode_off)
|
|
|
+ code, out = shell.call(namenode_safe_mode_off, user=params.hdfs_user)
|
|
|
if code != 0:
|
|
|
leave_safe_mode_cmd = format("hdfs --config {hadoop_conf_dir} dfsadmin -fs {namenode_address} -safemode leave")
|
|
|
Execute(leave_safe_mode_cmd,
|