Browse Source

AMBARI-18897. HBase conf directory should not have a copy of core-site.xml and hdfs-site.xml.(vbrodetskyi)

Vitaly Brodetskyi 8 years ago
parent
commit
3c3d3d23d4

+ 1 - 0
ambari-common/src/main/python/resource_management/libraries/functions/constants.py

@@ -102,3 +102,4 @@ class StackFeature:
   ATLAS_HBASE_SETUP = "atlas_hbase_setup"
   ATLAS_HBASE_SETUP = "atlas_hbase_setup"
   RANGER_HIVE_PLUGIN_JDBC_URL = "ranger_hive_plugin_jdbc_url"
   RANGER_HIVE_PLUGIN_JDBC_URL = "ranger_hive_plugin_jdbc_url"
   ZKFC_VERSION_ADVERTISED = "zkfc_version_advertised"
   ZKFC_VERSION_ADVERTISED = "zkfc_version_advertised"
+  PHOENIX_CORE_HDFS_SITE_REQUIRED = "phoenix_core_hdfs_site_required"

+ 23 - 23
ambari-server/src/main/resources/common-services/HBASE/0.96.0.2.0/package/scripts/hbase.py

@@ -22,7 +22,8 @@ from resource_management import *
 import sys
 import sys
 from ambari_commons.os_family_impl import OsFamilyFuncImpl, OsFamilyImpl
 from ambari_commons.os_family_impl import OsFamilyFuncImpl, OsFamilyImpl
 from ambari_commons import OSConst
 from ambari_commons import OSConst
-
+from resource_management.libraries.functions.constants import StackFeature
+from resource_management.libraries.functions.stack_features import check_stack_feature
 
 
 @OsFamilyFuncImpl(os_family=OSConst.WINSRV_FAMILY)
 @OsFamilyFuncImpl(os_family=OSConst.WINSRV_FAMILY)
 def hbase(name=None):
 def hbase(name=None):
@@ -95,29 +96,28 @@ def hbase(name=None):
             group = params.user_group
             group = params.user_group
   )
   )
 
 
-  XmlConfig( "core-site.xml",
-             conf_dir = params.hbase_conf_dir,
-             configurations = params.config['configurations']['core-site'],
-             configuration_attributes=params.config['configuration_attributes']['core-site'],
-             owner = params.hbase_user,
-             group = params.user_group
-  )
-
-  if 'hdfs-site' in params.config['configurations']:
-    XmlConfig( "hdfs-site.xml",
-            conf_dir = params.hbase_conf_dir,
-            configurations = params.config['configurations']['hdfs-site'],
-            configuration_attributes=params.config['configuration_attributes']['hdfs-site'],
-            owner = params.hbase_user,
-            group = params.user_group
+  if check_stack_feature(StackFeature.PHOENIX_CORE_HDFS_SITE_REQUIRED, params.version_for_stack_feature_checks):
+    XmlConfig( "core-site.xml",
+               conf_dir = params.hbase_conf_dir,
+               configurations = params.config['configurations']['core-site'],
+               configuration_attributes=params.config['configuration_attributes']['core-site'],
+               owner = params.hbase_user,
+               group = params.user_group
     )
     )
-
-    XmlConfig("hdfs-site.xml",
-            conf_dir=params.hadoop_conf_dir,
-            configurations=params.config['configurations']['hdfs-site'],
-            configuration_attributes=params.config['configuration_attributes']['hdfs-site'],
-            owner=params.hdfs_user,
-            group=params.user_group
+    if 'hdfs-site' in params.config['configurations']:
+      XmlConfig( "hdfs-site.xml",
+              conf_dir = params.hbase_conf_dir,
+              configurations = params.config['configurations']['hdfs-site'],
+              configuration_attributes=params.config['configuration_attributes']['hdfs-site'],
+              owner = params.hbase_user,
+              group = params.user_group
+      )
+  else:
+    File(format("{params.hbase_conf_dir}/hdfs-site.xml"),
+         action="delete"
+    )
+    File(format("{params.hbase_conf_dir}/core-site.xml"),
+         action="delete"
     )
     )
 
 
   if 'hbase-policy' in params.config['configurations']:
   if 'hbase-policy' in params.config['configurations']:

+ 5 - 0
ambari-server/src/main/resources/stacks/HDP/2.0.6/properties/stack_features.json

@@ -313,6 +313,11 @@
       "name": "zkfc_version_advertised",
       "name": "zkfc_version_advertised",
       "description": "ZKFC advertise version",
       "description": "ZKFC advertise version",
       "min_version": "2.5.0.0"
       "min_version": "2.5.0.0"
+    },
+    {
+      "name": "phoenix_core_hdfs_site_required",
+      "description": "HDFS and CORE site required for Phoenix",
+      "max_version": "2.5.9.9"
     }
     }
   ]
   ]
 }
 }

+ 0 - 14
ambari-server/src/test/python/stacks/2.0.6/HBASE/test_hbase_client.py

@@ -78,13 +78,6 @@ class TestHBaseClient(RMFTestCase):
       configurations = self.getConfig()['configurations']['hdfs-site'],
       configurations = self.getConfig()['configurations']['hdfs-site'],
       configuration_attributes = self.getConfig()['configuration_attributes']['hdfs-site']
       configuration_attributes = self.getConfig()['configuration_attributes']['hdfs-site']
     )
     )
-    self.assertResourceCalled('XmlConfig', 'hdfs-site.xml',
-      owner = 'hdfs',
-      group = 'hadoop',
-      conf_dir = '/etc/hadoop/conf',
-      configurations = self.getConfig()['configurations']['hdfs-site'],
-      configuration_attributes = self.getConfig()['configuration_attributes']['hdfs-site']
-    )
     self.assertResourceCalled('File', '/etc/hbase/conf/hbase-policy.xml',
     self.assertResourceCalled('File', '/etc/hbase/conf/hbase-policy.xml',
       owner = 'hbase',
       owner = 'hbase',
       group = 'hadoop',
       group = 'hadoop',
@@ -174,13 +167,6 @@ class TestHBaseClient(RMFTestCase):
       configurations = self.getConfig()['configurations']['hdfs-site'],
       configurations = self.getConfig()['configurations']['hdfs-site'],
       configuration_attributes = self.getConfig()['configuration_attributes']['hdfs-site']
       configuration_attributes = self.getConfig()['configuration_attributes']['hdfs-site']
     )
     )
-    self.assertResourceCalled('XmlConfig', 'hdfs-site.xml',
-      owner = 'hdfs',
-      group = 'hadoop',
-      conf_dir = '/etc/hadoop/conf',
-      configurations = self.getConfig()['configurations']['hdfs-site'],
-      configuration_attributes = self.getConfig()['configuration_attributes']['hdfs-site']
-    )
     self.assertResourceCalled('File', '/etc/hbase/conf/hbase-policy.xml',
     self.assertResourceCalled('File', '/etc/hbase/conf/hbase-policy.xml',
       owner = 'hbase',
       owner = 'hbase',
       group = 'hadoop',
       group = 'hadoop',

+ 0 - 21
ambari-server/src/test/python/stacks/2.0.6/HBASE/test_hbase_master.py

@@ -333,13 +333,6 @@ class TestHBaseMaster(RMFTestCase):
       configurations = self.getConfig()['configurations']['hdfs-site'],
       configurations = self.getConfig()['configurations']['hdfs-site'],
       configuration_attributes = self.getConfig()['configuration_attributes']['hdfs-site']
       configuration_attributes = self.getConfig()['configuration_attributes']['hdfs-site']
     )
     )
-    self.assertResourceCalled('XmlConfig', 'hdfs-site.xml',
-                              owner = 'hdfs',
-                              group = 'hadoop',
-                              conf_dir = '/etc/hadoop/conf',
-                              configurations = self.getConfig()['configurations']['hdfs-site'],
-                              configuration_attributes = self.getConfig()['configuration_attributes']['hdfs-site']
-    )
     self.assertResourceCalled('File', '/etc/hbase/conf/hbase-policy.xml',
     self.assertResourceCalled('File', '/etc/hbase/conf/hbase-policy.xml',
       owner = 'hbase',
       owner = 'hbase',
       group = 'hadoop'
       group = 'hadoop'
@@ -471,13 +464,6 @@ class TestHBaseMaster(RMFTestCase):
       configurations = self.getConfig()['configurations']['hdfs-site'],
       configurations = self.getConfig()['configurations']['hdfs-site'],
       configuration_attributes = self.getConfig()['configuration_attributes']['hdfs-site']
       configuration_attributes = self.getConfig()['configuration_attributes']['hdfs-site']
     )
     )
-    self.assertResourceCalled('XmlConfig', 'hdfs-site.xml',
-      owner = 'hdfs',
-      group = 'hadoop',
-      conf_dir = '/etc/hadoop/conf',
-      configurations = self.getConfig()['configurations']['hdfs-site'],
-      configuration_attributes = self.getConfig()['configuration_attributes']['hdfs-site']
-    )
     self.assertResourceCalled('File', '/etc/hbase/conf/hbase-policy.xml',
     self.assertResourceCalled('File', '/etc/hbase/conf/hbase-policy.xml',
       owner = 'hbase',
       owner = 'hbase',
       group = 'hadoop',
       group = 'hadoop',
@@ -620,13 +606,6 @@ class TestHBaseMaster(RMFTestCase):
       configurations = self.getConfig()['configurations']['hdfs-site'],
       configurations = self.getConfig()['configurations']['hdfs-site'],
       configuration_attributes = self.getConfig()['configuration_attributes']['hdfs-site'])
       configuration_attributes = self.getConfig()['configuration_attributes']['hdfs-site'])
 
 
-    self.assertResourceCalled('XmlConfig', 'hdfs-site.xml',
-                              owner = 'hdfs',
-                              group = 'hadoop',
-                              conf_dir = '/usr/hdp/current/hadoop-client/conf',
-                              configurations = self.getConfig()['configurations']['hdfs-site'],
-                              configuration_attributes = self.getConfig()['configuration_attributes']['hdfs-site'])
-
     self.assertResourceCalled('XmlConfig', 'hbase-policy.xml',
     self.assertResourceCalled('XmlConfig', 'hbase-policy.xml',
       owner = 'hbase',
       owner = 'hbase',
       group = 'hadoop',
       group = 'hadoop',

+ 0 - 28
ambari-server/src/test/python/stacks/2.0.6/HBASE/test_hbase_regionserver.py

@@ -170,13 +170,6 @@ class TestHbaseRegionServer(RMFTestCase):
       configurations = self.getConfig()['configurations']['hdfs-site'],
       configurations = self.getConfig()['configurations']['hdfs-site'],
       configuration_attributes = self.getConfig()['configuration_attributes']['hdfs-site']
       configuration_attributes = self.getConfig()['configuration_attributes']['hdfs-site']
     )
     )
-    self.assertResourceCalled('XmlConfig', 'hdfs-site.xml',
-      owner = 'hdfs',
-      group = 'hadoop',
-      conf_dir = '/etc/hadoop/conf',
-      configurations = self.getConfig()['configurations']['hdfs-site'],
-      configuration_attributes = self.getConfig()['configuration_attributes']['hdfs-site']
-    )
     self.assertResourceCalled('File', '/etc/hbase/conf/hbase-policy.xml',
     self.assertResourceCalled('File', '/etc/hbase/conf/hbase-policy.xml',
       owner = 'hbase',
       owner = 'hbase',
       group = 'hadoop',
       group = 'hadoop',
@@ -266,13 +259,6 @@ class TestHbaseRegionServer(RMFTestCase):
       configurations = self.getConfig()['configurations']['hdfs-site'],
       configurations = self.getConfig()['configurations']['hdfs-site'],
       configuration_attributes = self.getConfig()['configuration_attributes']['hdfs-site']
       configuration_attributes = self.getConfig()['configuration_attributes']['hdfs-site']
     )
     )
-    self.assertResourceCalled('XmlConfig', 'hdfs-site.xml',
-      owner = 'hdfs',
-      group = 'hadoop',
-      conf_dir = '/etc/hadoop/conf',
-      configurations = self.getConfig()['configurations']['hdfs-site'],
-      configuration_attributes = self.getConfig()['configuration_attributes']['hdfs-site']
-    )
     self.assertResourceCalled('File', '/etc/hbase/conf/hbase-policy.xml',
     self.assertResourceCalled('File', '/etc/hbase/conf/hbase-policy.xml',
       owner = 'hbase',
       owner = 'hbase',
       group = 'hadoop',
       group = 'hadoop',
@@ -374,13 +360,6 @@ class TestHbaseRegionServer(RMFTestCase):
       configurations = self.getConfig()['configurations']['hdfs-site'],
       configurations = self.getConfig()['configurations']['hdfs-site'],
       configuration_attributes = self.getConfig()['configuration_attributes']['hdfs-site'])
       configuration_attributes = self.getConfig()['configuration_attributes']['hdfs-site'])
 
 
-    self.assertResourceCalled('XmlConfig', 'hdfs-site.xml',
-                              owner = 'hdfs',
-                              group = 'hadoop',
-                              conf_dir = '/usr/hdp/current/hadoop-client/conf',
-                              configurations = self.getConfig()['configurations']['hdfs-site'],
-                              configuration_attributes = self.getConfig()['configuration_attributes']['hdfs-site'])
-
     self.assertResourceCalled('XmlConfig', 'hbase-policy.xml',
     self.assertResourceCalled('XmlConfig', 'hbase-policy.xml',
       owner = 'hbase',
       owner = 'hbase',
       group = 'hadoop',
       group = 'hadoop',
@@ -488,13 +467,6 @@ class TestHbaseRegionServer(RMFTestCase):
       configurations = self.getConfig()['configurations']['hdfs-site'],
       configurations = self.getConfig()['configurations']['hdfs-site'],
       configuration_attributes = self.getConfig()['configuration_attributes']['hdfs-site'])
       configuration_attributes = self.getConfig()['configuration_attributes']['hdfs-site'])
 
 
-    self.assertResourceCalled('XmlConfig', 'hdfs-site.xml',
-                              owner = 'hdfs',
-                              group = 'hadoop',
-                              conf_dir = '/usr/hdp/current/hadoop-client/conf',
-                              configurations = self.getConfig()['configurations']['hdfs-site'],
-                              configuration_attributes = self.getConfig()['configuration_attributes']['hdfs-site'])
-
     self.assertResourceCalled('XmlConfig', 'hbase-policy.xml',
     self.assertResourceCalled('XmlConfig', 'hbase-policy.xml',
       owner = 'hbase',
       owner = 'hbase',
       group = 'hadoop',
       group = 'hadoop',

+ 0 - 16
ambari-server/src/test/python/stacks/2.0.6/HBASE/test_phoenix_queryserver.py

@@ -273,14 +273,6 @@ class TestPhoenixQueryServer(RMFTestCase):
       configuration_attributes = self.getConfig()['configuration_attributes'][
       configuration_attributes = self.getConfig()['configuration_attributes'][
         'hdfs-site']
         'hdfs-site']
     )
     )
-    self.assertResourceCalled('XmlConfig', 'hdfs-site.xml',
-      owner = 'hdfs',
-      group = 'hadoop',
-      conf_dir = '/usr/hdp/current/hadoop-client/conf',
-      configurations = self.getConfig()['configurations']['hdfs-site'],
-      configuration_attributes = self.getConfig()['configuration_attributes'][
-        'hdfs-site']
-    )
     self.assertResourceCalled('XmlConfig', 'hbase-policy.xml',
     self.assertResourceCalled('XmlConfig', 'hbase-policy.xml',
       owner = 'hbase',
       owner = 'hbase',
       group = 'hadoop',
       group = 'hadoop',
@@ -384,14 +376,6 @@ class TestPhoenixQueryServer(RMFTestCase):
       configuration_attributes = self.getConfig()['configuration_attributes'][
       configuration_attributes = self.getConfig()['configuration_attributes'][
         'hdfs-site']
         'hdfs-site']
     )
     )
-    self.assertResourceCalled('XmlConfig', 'hdfs-site.xml',
-      owner = 'hdfs',
-      group = 'hadoop',
-      conf_dir = '/usr/hdp/current/hadoop-client/conf',
-      configurations = self.getConfig()['configurations']['hdfs-site'],
-      configuration_attributes = self.getConfig()['configuration_attributes'][
-        'hdfs-site']
-    )
     self.assertResourceCalled('XmlConfig', 'hbase-policy.xml',
     self.assertResourceCalled('XmlConfig', 'hbase-policy.xml',
       owner = 'hbase',
       owner = 'hbase',
       group = 'hadoop',
       group = 'hadoop',