|
@@ -31,20 +31,6 @@ class TestHiveServer(RMFTestCase):
|
|
|
config_file="default.json"
|
|
|
)
|
|
|
self.assert_configure_default()
|
|
|
- self.assertResourceCalled('File',
|
|
|
- '/etc/hive/conf/hive-exec-log4j.properties',
|
|
|
- mode=0644,
|
|
|
- group='hadoop',
|
|
|
- owner='hive',
|
|
|
- content='log4jproperties\nline2'
|
|
|
- )
|
|
|
- self.assertResourceCalled('File',
|
|
|
- '/etc/hive/conf/hive-log4j.properties',
|
|
|
- mode=0644,
|
|
|
- group='hadoop',
|
|
|
- owner='hive',
|
|
|
- content='log4jproperties\nline2'
|
|
|
- )
|
|
|
self.assertNoMoreResources()
|
|
|
|
|
|
@patch("hive_service.check_fs_root")
|
|
@@ -59,21 +45,6 @@ class TestHiveServer(RMFTestCase):
|
|
|
)
|
|
|
|
|
|
self.assert_configure_default()
|
|
|
- self.assertResourceCalled('File',
|
|
|
- '/etc/hive/conf/hive-exec-log4j.properties',
|
|
|
- mode=0644,
|
|
|
- group='hadoop',
|
|
|
- owner='hive',
|
|
|
- content='log4jproperties\nline2'
|
|
|
- )
|
|
|
- self.assertResourceCalled('File',
|
|
|
- '/etc/hive/conf/hive-log4j.properties',
|
|
|
- mode=0644,
|
|
|
- group='hadoop',
|
|
|
- owner='hive',
|
|
|
- content='log4jproperties\nline2'
|
|
|
- )
|
|
|
-
|
|
|
self.assertResourceCalled('HdfsDirectory', '/apps/tez/',
|
|
|
action = ['create_delayed'],
|
|
|
mode = 0755,
|
|
@@ -157,20 +128,6 @@ class TestHiveServer(RMFTestCase):
|
|
|
config_file="secured.json"
|
|
|
)
|
|
|
self.assert_configure_secured()
|
|
|
- self.assertResourceCalled('File',
|
|
|
- '/etc/hive/conf/hive-exec-log4j.properties',
|
|
|
- mode=0644,
|
|
|
- group='hadoop',
|
|
|
- owner='hive',
|
|
|
- content='log4jproperties\nline2'
|
|
|
- )
|
|
|
- self.assertResourceCalled('File',
|
|
|
- '/etc/hive/conf/hive-log4j.properties',
|
|
|
- mode=0644,
|
|
|
- group='hadoop',
|
|
|
- owner='hive',
|
|
|
- content='log4jproperties\nline2'
|
|
|
- )
|
|
|
self.assertNoMoreResources()
|
|
|
|
|
|
@patch("hive_service.check_fs_root")
|
|
@@ -185,20 +142,6 @@ class TestHiveServer(RMFTestCase):
|
|
|
)
|
|
|
|
|
|
self.assert_configure_secured()
|
|
|
- self.assertResourceCalled('File',
|
|
|
- '/etc/hive/conf/hive-exec-log4j.properties',
|
|
|
- mode=0644,
|
|
|
- group='hadoop',
|
|
|
- owner='hive',
|
|
|
- content='log4jproperties\nline2'
|
|
|
- )
|
|
|
- self.assertResourceCalled('File',
|
|
|
- '/etc/hive/conf/hive-log4j.properties',
|
|
|
- mode=0644,
|
|
|
- group='hadoop',
|
|
|
- owner='hive',
|
|
|
- content='log4jproperties\nline2'
|
|
|
- )
|
|
|
self.assertResourceCalled('Execute', 'env JAVA_HOME=/usr/jdk64/jdk1.7.0_45 /tmp/start_hiveserver2_script /var/log/hive/hive-server2.out /var/log/hive/hive-server2.log /var/run/hive/hive-server.pid /etc/hive/conf.server /var/log/hive',
|
|
|
not_if = 'ls /var/run/hive/hive-server.pid >/dev/null 2>&1 && ps `cat /var/run/hive/hive-server.pid` >/dev/null 2>&1',
|
|
|
user = 'hive'
|
|
@@ -230,245 +173,308 @@ class TestHiveServer(RMFTestCase):
|
|
|
|
|
|
def assert_configure_default(self):
|
|
|
self.assertResourceCalled('HdfsDirectory', '/apps/hive/warehouse',
|
|
|
- security_enabled = False,
|
|
|
- keytab = UnknownConfigurationMock(),
|
|
|
- conf_dir = '/etc/hadoop/conf',
|
|
|
- hdfs_user = 'hdfs',
|
|
|
- kinit_path_local = "/usr/bin/kinit",
|
|
|
- mode = 0777,
|
|
|
- owner = 'hive',
|
|
|
- action = ['create_delayed'],
|
|
|
- )
|
|
|
+ security_enabled = False,
|
|
|
+ keytab = UnknownConfigurationMock(),
|
|
|
+ conf_dir = '/etc/hadoop/conf',
|
|
|
+ hdfs_user = 'hdfs',
|
|
|
+ kinit_path_local = '/usr/bin/kinit',
|
|
|
+ mode = 0777,
|
|
|
+ owner = 'hive',
|
|
|
+ action = ['create_delayed'],
|
|
|
+ )
|
|
|
self.assertResourceCalled('HdfsDirectory', '/user/hive',
|
|
|
- security_enabled = False,
|
|
|
- keytab = UnknownConfigurationMock(),
|
|
|
- conf_dir = '/etc/hadoop/conf',
|
|
|
- hdfs_user = 'hdfs',
|
|
|
- kinit_path_local = "/usr/bin/kinit",
|
|
|
- mode = 0700,
|
|
|
- owner = 'hive',
|
|
|
- action = ['create_delayed'],
|
|
|
- )
|
|
|
+ security_enabled = False,
|
|
|
+ keytab = UnknownConfigurationMock(),
|
|
|
+ conf_dir = '/etc/hadoop/conf',
|
|
|
+ hdfs_user = 'hdfs',
|
|
|
+ kinit_path_local = '/usr/bin/kinit',
|
|
|
+ mode = 0700,
|
|
|
+ owner = 'hive',
|
|
|
+ action = ['create_delayed'],
|
|
|
+ )
|
|
|
self.assertResourceCalled('HdfsDirectory', None,
|
|
|
- security_enabled = False,
|
|
|
- keytab = UnknownConfigurationMock(),
|
|
|
- conf_dir = '/etc/hadoop/conf',
|
|
|
- hdfs_user = 'hdfs',
|
|
|
- kinit_path_local = "/usr/bin/kinit",
|
|
|
- action = ['create'],
|
|
|
- )
|
|
|
- self.assertResourceCalled('Execute', 'hive mkdir -p /tmp/AMBARI-artifacts/ ; cp /usr/share/java/mysql-connector-java.jar /usr/lib/hive/lib//mysql-connector-java.jar',
|
|
|
- creates = '/usr/lib/hive/lib//mysql-connector-java.jar',
|
|
|
- path = ['/bin', '/usr/bin/'],
|
|
|
- not_if = 'test -f /usr/lib/hive/lib//mysql-connector-java.jar',
|
|
|
+ security_enabled = False,
|
|
|
+ keytab = UnknownConfigurationMock(),
|
|
|
+ conf_dir = '/etc/hadoop/conf',
|
|
|
+ hdfs_user = 'hdfs',
|
|
|
+ kinit_path_local = '/usr/bin/kinit',
|
|
|
+ action = ['create'],
|
|
|
)
|
|
|
- self.assertResourceCalled('Directory', '/etc/hive/conf',
|
|
|
- owner = 'hive',
|
|
|
- group = 'hadoop',
|
|
|
- recursive = True,
|
|
|
- )
|
|
|
self.assertResourceCalled('Directory', '/etc/hive/conf.server',
|
|
|
- owner = 'hive',
|
|
|
- group = 'hadoop',
|
|
|
- recursive = True,
|
|
|
+ owner = 'hive',
|
|
|
+ group = 'hadoop',
|
|
|
+ recursive = True,
|
|
|
)
|
|
|
self.assertResourceCalled('XmlConfig', 'mapred-site.xml',
|
|
|
- owner = 'hive',
|
|
|
- group = 'hadoop',
|
|
|
- mode = 0644,
|
|
|
- conf_dir = '/etc/hive/conf',
|
|
|
- configurations = self.getConfig()['configurations']['mapred-site'],
|
|
|
- configuration_attributes = self.getConfig()['configuration_attributes']['mapred-site']
|
|
|
+ group = 'hadoop',
|
|
|
+ conf_dir = '/etc/hive/conf.server',
|
|
|
+ mode = 0644,
|
|
|
+ configuration_attributes = self.getConfig()['configuration_attributes']['mapred-site'],
|
|
|
+ owner = 'hive',
|
|
|
+ configurations = self.getConfig()['configurations']['mapred-site'],
|
|
|
)
|
|
|
self.assertResourceCalled('XmlConfig', 'hive-site.xml',
|
|
|
- owner = 'hive',
|
|
|
- group = 'hadoop',
|
|
|
- mode = 0644,
|
|
|
- conf_dir = '/etc/hive/conf',
|
|
|
- configurations = self.getConfig()['configurations']['hive-site'],
|
|
|
- configuration_attributes = self.getConfig()['configuration_attributes']['hive-site']
|
|
|
+ group = 'hadoop',
|
|
|
+ conf_dir = '/etc/hive/conf.server',
|
|
|
+ mode = 0644,
|
|
|
+ configuration_attributes = self.getConfig()['configuration_attributes']['hive-site'],
|
|
|
+ owner = 'hive',
|
|
|
+ configurations = self.getConfig()['configurations']['hive-site'],
|
|
|
+ )
|
|
|
+ self.assertResourceCalled('File', '/etc/hive/conf.server/hive-env.sh',
|
|
|
+ content = InlineTemplate(self.getConfig()['configurations']['hive-env']['content']),
|
|
|
+ owner = 'hive',
|
|
|
+ group = 'hadoop',
|
|
|
+ )
|
|
|
+ self.assertResourceCalled('File', '/etc/hive/conf.server/hive-default.xml.template',
|
|
|
+ owner = 'hive',
|
|
|
+ group = 'hadoop',
|
|
|
+ )
|
|
|
+ self.assertResourceCalled('File', '/etc/hive/conf.server/hive-env.sh.template',
|
|
|
+ owner = 'hive',
|
|
|
+ group = 'hadoop',
|
|
|
+ )
|
|
|
+ self.assertResourceCalled('File', '/etc/hive/conf.server/hive-exec-log4j.properties',
|
|
|
+ content = 'log4jproperties\nline2',
|
|
|
+ owner = 'hive',
|
|
|
+ group = 'hadoop',
|
|
|
+ mode = 0644,
|
|
|
+ )
|
|
|
+ self.assertResourceCalled('File', '/etc/hive/conf.server/hive-log4j.properties',
|
|
|
+ content = 'log4jproperties\nline2',
|
|
|
+ owner = 'hive',
|
|
|
+ group = 'hadoop',
|
|
|
+ mode = 0644,
|
|
|
+ )
|
|
|
+ self.assertResourceCalled('Directory', '/etc/hive/conf',
|
|
|
+ owner = 'hive',
|
|
|
+ group = 'hadoop',
|
|
|
+ recursive = True,
|
|
|
)
|
|
|
self.assertResourceCalled('XmlConfig', 'mapred-site.xml',
|
|
|
- owner = 'hive',
|
|
|
- group = 'hadoop',
|
|
|
- mode = 0600,
|
|
|
- conf_dir = '/etc/hive/conf.server',
|
|
|
- configurations = self.getConfig()['configurations']['mapred-site'],
|
|
|
- configuration_attributes = self.getConfig()['configuration_attributes']['mapred-site']
|
|
|
+ group = 'hadoop',
|
|
|
+ conf_dir = '/etc/hive/conf',
|
|
|
+ mode = 0644,
|
|
|
+ configuration_attributes = self.getConfig()['configuration_attributes']['mapred-site'],
|
|
|
+ owner = 'hive',
|
|
|
+ configurations = self.getConfig()['configurations']['mapred-site'],
|
|
|
)
|
|
|
self.assertResourceCalled('XmlConfig', 'hive-site.xml',
|
|
|
- owner = 'hive',
|
|
|
- group = 'hadoop',
|
|
|
- mode = 0600,
|
|
|
- conf_dir = '/etc/hive/conf.server',
|
|
|
- configurations = self.getConfig()['configurations']['hive-site'],
|
|
|
- configuration_attributes = self.getConfig()['configuration_attributes']['hive-site']
|
|
|
- )
|
|
|
- self.assertResourceCalled('Execute', "/bin/sh -c 'cd /usr/lib/ambari-agent/ && curl -kf -x \"\" --retry 5 http://c6401.ambari.apache.org:8080/resources/DBConnectionVerification.jar -o DBConnectionVerification.jar'",
|
|
|
- not_if = '[ -f DBConnectionVerification.jar]',
|
|
|
- environment = {'no_proxy': 'c6401.ambari.apache.org'}
|
|
|
+ group = 'hadoop',
|
|
|
+ conf_dir = '/etc/hive/conf',
|
|
|
+ mode = 0644,
|
|
|
+ configuration_attributes = self.getConfig()['configuration_attributes']['hive-site'],
|
|
|
+ owner = 'hive',
|
|
|
+ configurations = self.getConfig()['configurations']['hive-site'],
|
|
|
)
|
|
|
self.assertResourceCalled('File', '/etc/hive/conf/hive-env.sh',
|
|
|
- content = InlineTemplate(self.getConfig()['configurations']['hive-env']['content']),
|
|
|
- owner = 'hive',
|
|
|
- group = 'hadoop',
|
|
|
- )
|
|
|
- self.assertResourceCalled('File', '/etc/hive/conf.server/hive-env.sh',
|
|
|
- content = InlineTemplate(self.getConfig()['configurations']['hive-env']['content']),
|
|
|
- owner = 'hive',
|
|
|
- group = 'hadoop',
|
|
|
+ content = InlineTemplate(self.getConfig()['configurations']['hive-env']['content']),
|
|
|
+ owner = 'hive',
|
|
|
+ group = 'hadoop',
|
|
|
+ )
|
|
|
+ self.assertResourceCalled('File', '/etc/hive/conf/hive-default.xml.template',
|
|
|
+ owner = 'hive',
|
|
|
+ group = 'hadoop',
|
|
|
+ )
|
|
|
+ self.assertResourceCalled('File', '/etc/hive/conf/hive-env.sh.template',
|
|
|
+ owner = 'hive',
|
|
|
+ group = 'hadoop',
|
|
|
+ )
|
|
|
+ self.assertResourceCalled('File', '/etc/hive/conf/hive-exec-log4j.properties',
|
|
|
+ content = 'log4jproperties\nline2',
|
|
|
+ owner = 'hive',
|
|
|
+ group = 'hadoop',
|
|
|
+ mode = 0644,
|
|
|
+ )
|
|
|
+ self.assertResourceCalled('File', '/etc/hive/conf/hive-log4j.properties',
|
|
|
+ content = 'log4jproperties\nline2',
|
|
|
+ owner = 'hive',
|
|
|
+ group = 'hadoop',
|
|
|
+ mode = 0644,
|
|
|
+ )
|
|
|
+ self.assertResourceCalled('Execute', 'hive mkdir -p /tmp/AMBARI-artifacts/ ; cp /usr/share/java/mysql-connector-java.jar /usr/lib/hive/lib//mysql-connector-java.jar',
|
|
|
+ creates = '/usr/lib/hive/lib//mysql-connector-java.jar',
|
|
|
+ path = ['/bin', '/usr/bin/'],
|
|
|
+ not_if = 'test -f /usr/lib/hive/lib//mysql-connector-java.jar',
|
|
|
+ )
|
|
|
+ self.assertResourceCalled('Execute', '/bin/sh -c \'cd /usr/lib/ambari-agent/ && curl -kf -x "" --retry 5 http://c6401.ambari.apache.org:8080/resources/DBConnectionVerification.jar -o DBConnectionVerification.jar\'',
|
|
|
+ environment = {'no_proxy': 'c6401.ambari.apache.org'},
|
|
|
+ not_if = '[ -f DBConnectionVerification.jar]',
|
|
|
)
|
|
|
self.assertResourceCalled('File', '/tmp/start_hiveserver2_script',
|
|
|
- content = Template('startHiveserver2.sh.j2'),
|
|
|
- mode = 0755,
|
|
|
+ content = Template('startHiveserver2.sh.j2'),
|
|
|
+ mode = 0755,
|
|
|
)
|
|
|
self.assertResourceCalled('Directory', '/var/run/hive',
|
|
|
- owner = 'hive',
|
|
|
- group = 'hadoop',
|
|
|
- mode = 0755,
|
|
|
- recursive = True,
|
|
|
+ owner = 'hive',
|
|
|
+ group = 'hadoop',
|
|
|
+ mode = 0755,
|
|
|
+ recursive = True,
|
|
|
)
|
|
|
self.assertResourceCalled('Directory', '/var/log/hive',
|
|
|
- owner = 'hive',
|
|
|
- group = 'hadoop',
|
|
|
- mode = 0755,
|
|
|
- recursive = True,
|
|
|
+ owner = 'hive',
|
|
|
+ group = 'hadoop',
|
|
|
+ mode = 0755,
|
|
|
+ recursive = True,
|
|
|
)
|
|
|
self.assertResourceCalled('Directory', '/var/lib/hive',
|
|
|
- owner = 'hive',
|
|
|
- group = 'hadoop',
|
|
|
- mode = 0755,
|
|
|
- recursive = True,
|
|
|
- )
|
|
|
- self.assertResourceCalled('File', '/etc/hive/conf/hive-default.xml.template',
|
|
|
- owner = 'hive',
|
|
|
- group = 'hadoop',
|
|
|
+ owner = 'hive',
|
|
|
+ group = 'hadoop',
|
|
|
+ mode = 0755,
|
|
|
+ recursive = True,
|
|
|
)
|
|
|
- self.assertResourceCalled('File', '/etc/hive/conf/hive-env.sh.template',
|
|
|
- owner = 'hive',
|
|
|
- group = 'hadoop',
|
|
|
- )
|
|
|
-
|
|
|
+
|
|
|
def assert_configure_secured(self):
|
|
|
self.assertResourceCalled('HdfsDirectory', '/apps/hive/warehouse',
|
|
|
- security_enabled = True,
|
|
|
- keytab = '/etc/security/keytabs/hdfs.headless.keytab',
|
|
|
- conf_dir = '/etc/hadoop/conf',
|
|
|
- hdfs_user = 'hdfs',
|
|
|
- kinit_path_local = '/usr/bin/kinit',
|
|
|
- mode = 0777,
|
|
|
- owner = 'hive',
|
|
|
- action = ['create_delayed'],
|
|
|
- )
|
|
|
+ security_enabled = True,
|
|
|
+ keytab = '/etc/security/keytabs/hdfs.headless.keytab',
|
|
|
+ conf_dir = '/etc/hadoop/conf',
|
|
|
+ hdfs_user = 'hdfs',
|
|
|
+ kinit_path_local = '/usr/bin/kinit',
|
|
|
+ mode = 0777,
|
|
|
+ owner = 'hive',
|
|
|
+ action = ['create_delayed'],
|
|
|
+ )
|
|
|
self.assertResourceCalled('HdfsDirectory', '/user/hive',
|
|
|
- security_enabled = True,
|
|
|
- keytab = '/etc/security/keytabs/hdfs.headless.keytab',
|
|
|
- conf_dir = '/etc/hadoop/conf',
|
|
|
- hdfs_user = 'hdfs',
|
|
|
- kinit_path_local = '/usr/bin/kinit',
|
|
|
- mode = 0700,
|
|
|
- owner = 'hive',
|
|
|
- action = ['create_delayed'],
|
|
|
- )
|
|
|
+ security_enabled = True,
|
|
|
+ keytab = '/etc/security/keytabs/hdfs.headless.keytab',
|
|
|
+ conf_dir = '/etc/hadoop/conf',
|
|
|
+ hdfs_user = 'hdfs',
|
|
|
+ kinit_path_local = '/usr/bin/kinit',
|
|
|
+ mode = 0700,
|
|
|
+ owner = 'hive',
|
|
|
+ action = ['create_delayed'],
|
|
|
+ )
|
|
|
self.assertResourceCalled('HdfsDirectory', None,
|
|
|
- security_enabled = True,
|
|
|
- keytab = '/etc/security/keytabs/hdfs.headless.keytab',
|
|
|
- conf_dir = '/etc/hadoop/conf',
|
|
|
- hdfs_user = 'hdfs',
|
|
|
- kinit_path_local = '/usr/bin/kinit',
|
|
|
- action = ['create'],
|
|
|
- )
|
|
|
-
|
|
|
- self.assertResourceCalled('Execute', 'hive mkdir -p /tmp/AMBARI-artifacts/ ; cp /usr/share/java/mysql-connector-java.jar /usr/lib/hive/lib//mysql-connector-java.jar',
|
|
|
- creates = '/usr/lib/hive/lib//mysql-connector-java.jar',
|
|
|
- path = ['/bin', '/usr/bin/'],
|
|
|
- not_if = 'test -f /usr/lib/hive/lib//mysql-connector-java.jar',
|
|
|
+ security_enabled = True,
|
|
|
+ keytab = '/etc/security/keytabs/hdfs.headless.keytab',
|
|
|
+ conf_dir = '/etc/hadoop/conf',
|
|
|
+ hdfs_user = 'hdfs',
|
|
|
+ kinit_path_local = '/usr/bin/kinit',
|
|
|
+ action = ['create'],
|
|
|
)
|
|
|
- self.assertResourceCalled('Directory', '/etc/hive/conf',
|
|
|
- owner = 'hive',
|
|
|
- group = 'hadoop',
|
|
|
- recursive = True,
|
|
|
- )
|
|
|
self.assertResourceCalled('Directory', '/etc/hive/conf.server',
|
|
|
- owner = 'hive',
|
|
|
- group = 'hadoop',
|
|
|
- recursive = True,
|
|
|
+ owner = 'hive',
|
|
|
+ group = 'hadoop',
|
|
|
+ recursive = True,
|
|
|
)
|
|
|
self.assertResourceCalled('XmlConfig', 'mapred-site.xml',
|
|
|
- owner = 'hive',
|
|
|
- group = 'hadoop',
|
|
|
- mode = 0644,
|
|
|
- conf_dir = '/etc/hive/conf',
|
|
|
- configurations = self.getConfig()['configurations']['mapred-site'],
|
|
|
- configuration_attributes = self.getConfig()['configuration_attributes']['mapred-site']
|
|
|
+ group = 'hadoop',
|
|
|
+ conf_dir = '/etc/hive/conf.server',
|
|
|
+ mode = 0644,
|
|
|
+ configuration_attributes = self.getConfig()['configuration_attributes']['mapred-site'],
|
|
|
+ owner = 'hive',
|
|
|
+ configurations = self.getConfig()['configurations']['mapred-site'],
|
|
|
)
|
|
|
self.assertResourceCalled('XmlConfig', 'hive-site.xml',
|
|
|
- owner = 'hive',
|
|
|
- group = 'hadoop',
|
|
|
- mode = 0644,
|
|
|
- conf_dir = '/etc/hive/conf',
|
|
|
- configurations = self.getConfig()['configurations']['hive-site'],
|
|
|
- configuration_attributes = self.getConfig()['configuration_attributes']['hive-site']
|
|
|
+ group = 'hadoop',
|
|
|
+ conf_dir = '/etc/hive/conf.server',
|
|
|
+ mode = 0644,
|
|
|
+ configuration_attributes = self.getConfig()['configuration_attributes']['hive-site'],
|
|
|
+ owner = 'hive',
|
|
|
+ configurations = self.getConfig()['configurations']['hive-site'],
|
|
|
+ )
|
|
|
+ self.assertResourceCalled('File', '/etc/hive/conf.server/hive-env.sh',
|
|
|
+ content = InlineTemplate(self.getConfig()['configurations']['hive-env']['content']),
|
|
|
+ owner = 'hive',
|
|
|
+ group = 'hadoop',
|
|
|
+ )
|
|
|
+ self.assertResourceCalled('File', '/etc/hive/conf.server/hive-default.xml.template',
|
|
|
+ owner = 'hive',
|
|
|
+ group = 'hadoop',
|
|
|
+ )
|
|
|
+ self.assertResourceCalled('File', '/etc/hive/conf.server/hive-env.sh.template',
|
|
|
+ owner = 'hive',
|
|
|
+ group = 'hadoop',
|
|
|
+ )
|
|
|
+ self.assertResourceCalled('File', '/etc/hive/conf.server/hive-exec-log4j.properties',
|
|
|
+ content = 'log4jproperties\nline2',
|
|
|
+ owner = 'hive',
|
|
|
+ group = 'hadoop',
|
|
|
+ mode = 0644,
|
|
|
+ )
|
|
|
+ self.assertResourceCalled('File', '/etc/hive/conf.server/hive-log4j.properties',
|
|
|
+ content = 'log4jproperties\nline2',
|
|
|
+ owner = 'hive',
|
|
|
+ group = 'hadoop',
|
|
|
+ mode = 0644,
|
|
|
+ )
|
|
|
+ self.assertResourceCalled('Directory', '/etc/hive/conf',
|
|
|
+ owner = 'hive',
|
|
|
+ group = 'hadoop',
|
|
|
+ recursive = True,
|
|
|
)
|
|
|
self.assertResourceCalled('XmlConfig', 'mapred-site.xml',
|
|
|
- owner = 'hive',
|
|
|
- group = 'hadoop',
|
|
|
- mode = 0600,
|
|
|
- conf_dir = '/etc/hive/conf.server',
|
|
|
- configurations = self.getConfig()['configurations']['mapred-site'],
|
|
|
- configuration_attributes = self.getConfig()['configuration_attributes']['mapred-site']
|
|
|
+ group = 'hadoop',
|
|
|
+ conf_dir = '/etc/hive/conf',
|
|
|
+ mode = 0644,
|
|
|
+ configuration_attributes = self.getConfig()['configuration_attributes']['mapred-site'],
|
|
|
+ owner = 'hive',
|
|
|
+ configurations = self.getConfig()['configurations']['mapred-site'],
|
|
|
)
|
|
|
self.assertResourceCalled('XmlConfig', 'hive-site.xml',
|
|
|
- owner = 'hive',
|
|
|
- group = 'hadoop',
|
|
|
- mode = 0600,
|
|
|
- conf_dir = '/etc/hive/conf.server',
|
|
|
- configurations = self.getConfig()['configurations']['hive-site'],
|
|
|
- configuration_attributes = self.getConfig()['configuration_attributes']['hive-site']
|
|
|
- )
|
|
|
- self.assertResourceCalled('Execute', "/bin/sh -c 'cd /usr/lib/ambari-agent/ && curl -kf -x \"\" --retry 5 http://c6401.ambari.apache.org:8080/resources/DBConnectionVerification.jar -o DBConnectionVerification.jar'",
|
|
|
- not_if = '[ -f DBConnectionVerification.jar]',
|
|
|
- environment = {'no_proxy': 'c6401.ambari.apache.org'}
|
|
|
+ group = 'hadoop',
|
|
|
+ conf_dir = '/etc/hive/conf',
|
|
|
+ mode = 0644,
|
|
|
+ configuration_attributes = self.getConfig()['configuration_attributes']['hive-site'],
|
|
|
+ owner = 'hive',
|
|
|
+ configurations = self.getConfig()['configurations']['hive-site'],
|
|
|
)
|
|
|
self.assertResourceCalled('File', '/etc/hive/conf/hive-env.sh',
|
|
|
- content = InlineTemplate(self.getConfig()['configurations']['hive-env']['content']),
|
|
|
- owner = 'hive',
|
|
|
- group = 'hadoop',
|
|
|
- )
|
|
|
- self.assertResourceCalled('File', '/etc/hive/conf.server/hive-env.sh',
|
|
|
- content = InlineTemplate(self.getConfig()['configurations']['hive-env']['content']),
|
|
|
- owner = 'hive',
|
|
|
- group = 'hadoop',
|
|
|
+ content = InlineTemplate(self.getConfig()['configurations']['hive-env']['content']),
|
|
|
+ owner = 'hive',
|
|
|
+ group = 'hadoop',
|
|
|
+ )
|
|
|
+ self.assertResourceCalled('File', '/etc/hive/conf/hive-default.xml.template',
|
|
|
+ owner = 'hive',
|
|
|
+ group = 'hadoop',
|
|
|
+ )
|
|
|
+ self.assertResourceCalled('File', '/etc/hive/conf/hive-env.sh.template',
|
|
|
+ owner = 'hive',
|
|
|
+ group = 'hadoop',
|
|
|
+ )
|
|
|
+ self.assertResourceCalled('File', '/etc/hive/conf/hive-exec-log4j.properties',
|
|
|
+ content = 'log4jproperties\nline2',
|
|
|
+ owner = 'hive',
|
|
|
+ group = 'hadoop',
|
|
|
+ mode = 0644,
|
|
|
+ )
|
|
|
+ self.assertResourceCalled('File', '/etc/hive/conf/hive-log4j.properties',
|
|
|
+ content = 'log4jproperties\nline2',
|
|
|
+ owner = 'hive',
|
|
|
+ group = 'hadoop',
|
|
|
+ mode = 0644,
|
|
|
+ )
|
|
|
+ self.assertResourceCalled('Execute', 'hive mkdir -p /tmp/AMBARI-artifacts/ ; cp /usr/share/java/mysql-connector-java.jar /usr/lib/hive/lib//mysql-connector-java.jar',
|
|
|
+ creates = '/usr/lib/hive/lib//mysql-connector-java.jar',
|
|
|
+ path = ['/bin', '/usr/bin/'],
|
|
|
+ not_if = 'test -f /usr/lib/hive/lib//mysql-connector-java.jar',
|
|
|
+ )
|
|
|
+ self.assertResourceCalled('Execute', '/bin/sh -c \'cd /usr/lib/ambari-agent/ && curl -kf -x "" --retry 5 http://c6401.ambari.apache.org:8080/resources/DBConnectionVerification.jar -o DBConnectionVerification.jar\'',
|
|
|
+ environment = {'no_proxy': 'c6401.ambari.apache.org'},
|
|
|
+ not_if = '[ -f DBConnectionVerification.jar]',
|
|
|
)
|
|
|
self.assertResourceCalled('File', '/tmp/start_hiveserver2_script',
|
|
|
- content = Template('startHiveserver2.sh.j2'),
|
|
|
- mode = 0755,
|
|
|
+ content = Template('startHiveserver2.sh.j2'),
|
|
|
+ mode = 0755,
|
|
|
)
|
|
|
self.assertResourceCalled('Directory', '/var/run/hive',
|
|
|
- owner = 'hive',
|
|
|
- group = 'hadoop',
|
|
|
- mode = 0755,
|
|
|
- recursive = True,
|
|
|
+ owner = 'hive',
|
|
|
+ group = 'hadoop',
|
|
|
+ mode = 0755,
|
|
|
+ recursive = True,
|
|
|
)
|
|
|
self.assertResourceCalled('Directory', '/var/log/hive',
|
|
|
- owner = 'hive',
|
|
|
- group = 'hadoop',
|
|
|
- mode = 0755,
|
|
|
- recursive = True,
|
|
|
+ owner = 'hive',
|
|
|
+ group = 'hadoop',
|
|
|
+ mode = 0755,
|
|
|
+ recursive = True,
|
|
|
)
|
|
|
self.assertResourceCalled('Directory', '/var/lib/hive',
|
|
|
- owner = 'hive',
|
|
|
- group = 'hadoop',
|
|
|
- mode = 0755,
|
|
|
- recursive = True,
|
|
|
- )
|
|
|
- self.assertResourceCalled('File', '/etc/hive/conf/hive-default.xml.template',
|
|
|
- owner = 'hive',
|
|
|
- group = 'hadoop',
|
|
|
- )
|
|
|
- self.assertResourceCalled('File', '/etc/hive/conf/hive-env.sh.template',
|
|
|
- owner = 'hive',
|
|
|
- group = 'hadoop',
|
|
|
+ owner = 'hive',
|
|
|
+ group = 'hadoop',
|
|
|
+ mode = 0755,
|
|
|
+ recursive = True,
|
|
|
)
|
|
|
|
|
|
@patch("hive_service.check_fs_root")
|