[ambari] branch trunk updated: AMBARI-24904. JAR does not exist: /var/lib/ambari-agent/lib/fast-hdfs-resource.jar (aonishuk)

[ao...@apache.org]

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 3d21552  AMBARI-24904. JAR does not exist: /var/lib/ambari-agent/lib/fast-hdfs-resource.jar (aonishuk)
3d21552 is described below

commit 3d215524b279bf106a6950e36808f392cc2567b4
Author: Andrew Onishuk <ao...@hortonworks.com>
AuthorDate: Thu Nov 15 13:29:25 2018 +0200

    AMBARI-24904. JAR does not exist: /var/lib/ambari-agent/lib/fast-hdfs-resource.jar (aonishuk)
---
 .../python/resource_management/libraries/providers/hdfs_resource.py | 6 +++---
 1 file changed, 3 insertions(+), 3 deletions(-)

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 70d2a27..52b501d 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
@@ -206,7 +206,7 @@ class WebHDFSUtil:
   @staticmethod
   def is_webhdfs_available(is_webhdfs_enabled, dfs_type):
     # only hdfs seems to support webHDFS
-    return (is_webhdfs_enabled and dfs_type == 'HDFS')
+    return (is_webhdfs_enabled and dfs_type == 'hdfs')
     
   def run_command(self, *args, **kwargs):
     """
@@ -625,10 +625,10 @@ class HdfsResourceProvider(Provider):
       return
 
     self.assert_parameter_is_set('dfs_type')
-    self.fsType = getattr(resource, 'dfs_type')
+    self.fsType = getattr(resource, 'dfs_type').lower()
     self.can_use_webhdfs = True
 
-    if self.fsType == 'HDFS':
+    if self.fsType == 'hdfs':
       self.assert_parameter_is_set('hdfs_site')
       self.webhdfs_enabled = self.resource.hdfs_site['dfs.webhdfs.enabled']
     else: