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 <aonis...@hortonworks.com>
Authored: Thu Jun 29 20:44:14 2017 +0300
Committer: Andrew Onishuk <aonis...@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() == "":

Reply via email to