Repository: ambari Updated Branches: refs/heads/trunk 84cac5e4b -> ebabac069
AMBARI-19402. dfs.exclude file does not exist when deploying cluster with NN HA + kerberos via BP. Part2.(vbrodetskyi) Project: http://git-wip-us.apache.org/repos/asf/ambari/repo Commit: http://git-wip-us.apache.org/repos/asf/ambari/commit/ebabac06 Tree: http://git-wip-us.apache.org/repos/asf/ambari/tree/ebabac06 Diff: http://git-wip-us.apache.org/repos/asf/ambari/diff/ebabac06 Branch: refs/heads/trunk Commit: ebabac06969a499efa0a76028bf7ffbb823c3a0e Parents: 84cac5e Author: Vitaly Brodetskyi <[email protected]> Authored: Fri Jan 6 19:41:32 2017 +0200 Committer: Vitaly Brodetskyi <[email protected]> Committed: Fri Jan 6 19:42:10 2017 +0200 ---------------------------------------------------------------------- .../HDFS/3.0.0.3.0/package/scripts/hdfs_namenode.py | 7 ++++--- 1 file changed, 4 insertions(+), 3 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/ambari/blob/ebabac06/ambari-server/src/main/resources/common-services/HDFS/3.0.0.3.0/package/scripts/hdfs_namenode.py ---------------------------------------------------------------------- diff --git a/ambari-server/src/main/resources/common-services/HDFS/3.0.0.3.0/package/scripts/hdfs_namenode.py b/ambari-server/src/main/resources/common-services/HDFS/3.0.0.3.0/package/scripts/hdfs_namenode.py index 23119f0..4ac56fc 100644 --- a/ambari-server/src/main/resources/common-services/HDFS/3.0.0.3.0/package/scripts/hdfs_namenode.py +++ b/ambari-server/src/main/resources/common-services/HDFS/3.0.0.3.0/package/scripts/hdfs_namenode.py @@ -97,9 +97,6 @@ def namenode(action=None, hdfs_binary=None, do_format=True, upgrade_type=None, Logger.info("Called service {0} with upgrade_type: {1}".format(action, str(upgrade_type))) setup_ranger_hdfs(upgrade_type=upgrade_type) import params - if do_format and not params.hdfs_namenode_format_disabled: - format_namenode() - pass File(params.exclude_file_path, content=Template("exclude_hosts_list.j2"), @@ -107,6 +104,10 @@ def namenode(action=None, hdfs_binary=None, do_format=True, upgrade_type=None, group=params.user_group ) + if do_format and not params.hdfs_namenode_format_disabled: + format_namenode() + pass + if params.dfs_ha_enabled and \ params.dfs_ha_namenode_standby is not None and \ params.hostname == params.dfs_ha_namenode_standby:
