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]