You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@ambari.apache.org by ao...@apache.org on 2017/06/29 17:44:46 UTC
[2/2] ambari git commit: AMBARI-21376. Using URI naming format in
dfs.datanode.data.dir causing datanodes startup failure (aonishuk)
AMBARI-21376. Using URI naming format in dfs.datanode.data.dir causing datanodes startup failure (aonishuk)
Project: http://git-wip-us.apache.org/repos/asf/ambari/repo
Commit: http://git-wip-us.apache.org/repos/asf/ambari/commit/2f162cac
Tree: http://git-wip-us.apache.org/repos/asf/ambari/tree/2f162cac
Diff: http://git-wip-us.apache.org/repos/asf/ambari/diff/2f162cac
Branch: refs/heads/branch-2.5
Commit: 2f162cace09cb51ad20c0bed96f79cdeda02c598
Parents: fde1cce
Author: Andrew Onishuk <ao...@hortonworks.com>
Authored: Thu Jun 29 20:44:14 2017 +0300
Committer: Andrew Onishuk <ao...@hortonworks.com>
Committed: Thu Jun 29 20:44:14 2017 +0300
----------------------------------------------------------------------
.../resource_management/libraries/functions/mounted_dirs_helper.py | 1 +
1 file changed, 1 insertion(+)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/ambari/blob/2f162cac/ambari-common/src/main/python/resource_management/libraries/functions/mounted_dirs_helper.py
----------------------------------------------------------------------
diff --git a/ambari-common/src/main/python/resource_management/libraries/functions/mounted_dirs_helper.py b/ambari-common/src/main/python/resource_management/libraries/functions/mounted_dirs_helper.py
index 0ebd7e2..712eacf 100644
--- a/ambari-common/src/main/python/resource_management/libraries/functions/mounted_dirs_helper.py
+++ b/ambari-common/src/main/python/resource_management/libraries/functions/mounted_dirs_helper.py
@@ -115,6 +115,7 @@ def handle_mounted_dirs(func, dirs_string, history_filename, update_cache=True):
dirs_unmounted = set() # set of dirs that have become unmounted
valid_existing_dirs = []
+ dirs_string = dirs_string.replace("file:///","/")
dirs_string = ",".join([re.sub(r'^\[.+\]', '', dfs_dir.strip()) for dfs_dir in dirs_string.split(",")])
for dir in dirs_string.split(","):
if dir is None or dir.strip() == "":