|
|
@@ -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]
|