This is an automated email from the ASF dual-hosted git repository.

aonishuk 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 6a2ddb7  AMBARI-24839. Ambari is trying to create hbase.rootdir using 
s3 url (aonishuk)
6a2ddb7 is described below

commit 6a2ddb7d91c1f723140a5e6b6830667fef4aa5ca
Author: Andrew Onishuk <[email protected]>
AuthorDate: Mon Nov 5 10:44:16 2018 +0200

    AMBARI-24839. Ambari is trying to create hbase.rootdir using s3 url 
(aonishuk)
---
 .../resource_management/libraries/providers/hdfs_resource.py       | 7 +++++++
 1 file changed, 7 insertions(+)

diff --git 
a/ambari-common/src/main/python/resource_management/libraries/providers/hdfs_resource.py
 
b/ambari-common/src/main/python/resource_management/libraries/providers/hdfs_resource.py
index 8f56539..f74382c 100644
--- 
a/ambari-common/src/main/python/resource_management/libraries/providers/hdfs_resource.py
+++ 
b/ambari-common/src/main/python/resource_management/libraries/providers/hdfs_resource.py
@@ -660,6 +660,13 @@ class HdfsResourceProvider(Provider):
   def action_delayed(self, action_name):
     self.assert_parameter_is_set('type')
     
+    path_protocol = urlparse(self.resource.target).scheme.lower()
+    default_fs_protocol = urlparse(self.resource.default_fs).scheme.lower()
+
+    if path_protocol == "s3a" or default_fs_protocol == "s3a" and 
path_protocol == None:
+      Logger.info("Skipping creation of {0} in {1} since auto-creation of s3a 
resource is currently not supported.".format(self.resource.target, 
self.resource.default_fs))
+      return
+
     parsed_path = HdfsResourceProvider.parse_path(self.resource.target)
 
     parsed_not_managed_paths = [HdfsResourceProvider.parse_path(path) for path 
in self.resource.immutable_paths]

Reply via email to