|
@@ -88,7 +88,6 @@ class TestNamenode(RMFTestCase):
|
|
|
environment = {'HADOOP_LIBEXEC_DIR': '/usr/lib/hadoop/libexec'},
|
|
|
not_if = 'ls /var/run/hadoop/hdfs/hadoop-hdfs-namenode.pid >/dev/null 2>&1 && ps -p `cat /var/run/hadoop/hdfs/hadoop-hdfs-namenode.pid` >/dev/null 2>&1',
|
|
|
)
|
|
|
- self.printResources()
|
|
|
self.assertResourceCalled('Execute', 'hdfs --config /etc/hadoop/conf dfsadmin -safemode leave',
|
|
|
path = ['/usr/bin'],
|
|
|
user = 'hdfs',
|
|
@@ -100,38 +99,42 @@ class TestNamenode(RMFTestCase):
|
|
|
user = 'hdfs',
|
|
|
try_sleep = 10,
|
|
|
)
|
|
|
- self.assertResourceCalled('HdfsDirectory', '/tmp',
|
|
|
- security_enabled = False,
|
|
|
- keytab = UnknownConfigurationMock(),
|
|
|
- conf_dir = '/etc/hadoop/conf',
|
|
|
- hdfs_user = 'hdfs',
|
|
|
- kinit_path_local = '/usr/bin/kinit',
|
|
|
- mode = 0777,
|
|
|
- owner = 'hdfs',
|
|
|
- bin_dir = '/usr/bin',
|
|
|
- action = ['create_delayed'],
|
|
|
- )
|
|
|
- self.assertResourceCalled('HdfsDirectory', '/user/ambari-qa',
|
|
|
- security_enabled = False,
|
|
|
- keytab = UnknownConfigurationMock(),
|
|
|
- conf_dir = '/etc/hadoop/conf',
|
|
|
- hdfs_user = 'hdfs',
|
|
|
- kinit_path_local = '/usr/bin/kinit',
|
|
|
- mode = 0770,
|
|
|
- owner = 'ambari-qa',
|
|
|
- bin_dir = '/usr/bin',
|
|
|
- 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'],
|
|
|
- bin_dir = '/usr/bin',
|
|
|
- only_if = None,
|
|
|
- )
|
|
|
+ self.assertResourceCalled('HdfsResource', '/tmp',
|
|
|
+ security_enabled = False,
|
|
|
+ hadoop_conf_dir = '/etc/hadoop/conf',
|
|
|
+ keytab = UnknownConfigurationMock(),
|
|
|
+ hadoop_fs = 'hdfs://c6401.ambari.apache.org:8020',
|
|
|
+ kinit_path_local = '/usr/bin/kinit',
|
|
|
+ user = 'hdfs',
|
|
|
+ owner = 'hdfs',
|
|
|
+ hadoop_bin_dir = '/usr/bin',
|
|
|
+ type = 'directory',
|
|
|
+ action = ['create_delayed'],
|
|
|
+ mode = 0777,
|
|
|
+ )
|
|
|
+ self.assertResourceCalled('HdfsResource', '/user/ambari-qa',
|
|
|
+ security_enabled = False,
|
|
|
+ hadoop_conf_dir = '/etc/hadoop/conf',
|
|
|
+ keytab = UnknownConfigurationMock(),
|
|
|
+ hadoop_fs = 'hdfs://c6401.ambari.apache.org:8020',
|
|
|
+ kinit_path_local = '/usr/bin/kinit',
|
|
|
+ user = 'hdfs',
|
|
|
+ owner = 'ambari-qa',
|
|
|
+ hadoop_bin_dir = '/usr/bin',
|
|
|
+ type = 'directory',
|
|
|
+ action = ['create_delayed'],
|
|
|
+ mode = 0770,
|
|
|
+ )
|
|
|
+ self.assertResourceCalled('HdfsResource', None,
|
|
|
+ security_enabled = False,
|
|
|
+ hadoop_bin_dir = '/usr/bin',
|
|
|
+ keytab = UnknownConfigurationMock(),
|
|
|
+ hadoop_fs = 'hdfs://c6401.ambari.apache.org:8020',
|
|
|
+ kinit_path_local = '/usr/bin/kinit',
|
|
|
+ user = 'hdfs',
|
|
|
+ action = ['execute'],
|
|
|
+ hadoop_conf_dir = '/etc/hadoop/conf',
|
|
|
+ )
|
|
|
self.assertNoMoreResources()
|
|
|
|
|
|
def test_stop_default(self):
|
|
@@ -226,38 +229,42 @@ class TestNamenode(RMFTestCase):
|
|
|
user = 'hdfs',
|
|
|
try_sleep = 10,
|
|
|
)
|
|
|
- self.assertResourceCalled('HdfsDirectory', '/tmp',
|
|
|
- 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 = 'hdfs',
|
|
|
- bin_dir = '/usr/bin',
|
|
|
- action = ['create_delayed'],
|
|
|
- )
|
|
|
- self.assertResourceCalled('HdfsDirectory', '/user/ambari-qa',
|
|
|
- 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 = 0770,
|
|
|
- owner = 'ambari-qa',
|
|
|
- bin_dir = '/usr/bin',
|
|
|
- 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'],
|
|
|
- bin_dir = '/usr/bin',
|
|
|
- only_if = None,
|
|
|
- )
|
|
|
+ self.assertResourceCalled('HdfsResource', '/tmp',
|
|
|
+ security_enabled = True,
|
|
|
+ hadoop_conf_dir = '/etc/hadoop/conf',
|
|
|
+ keytab = '/etc/security/keytabs/hdfs.headless.keytab',
|
|
|
+ hadoop_fs = 'hdfs://c6401.ambari.apache.org:8020',
|
|
|
+ kinit_path_local = '/usr/bin/kinit',
|
|
|
+ user = 'hdfs',
|
|
|
+ owner = 'hdfs',
|
|
|
+ hadoop_bin_dir = '/usr/bin',
|
|
|
+ type = 'directory',
|
|
|
+ action = ['create_delayed'],
|
|
|
+ mode = 0777,
|
|
|
+ )
|
|
|
+ self.assertResourceCalled('HdfsResource', '/user/ambari-qa',
|
|
|
+ security_enabled = True,
|
|
|
+ hadoop_conf_dir = '/etc/hadoop/conf',
|
|
|
+ keytab = '/etc/security/keytabs/hdfs.headless.keytab',
|
|
|
+ hadoop_fs = 'hdfs://c6401.ambari.apache.org:8020',
|
|
|
+ kinit_path_local = '/usr/bin/kinit',
|
|
|
+ user = 'hdfs',
|
|
|
+ owner = 'ambari-qa',
|
|
|
+ hadoop_bin_dir = '/usr/bin',
|
|
|
+ type = 'directory',
|
|
|
+ action = ['create_delayed'],
|
|
|
+ mode = 0770,
|
|
|
+ )
|
|
|
+ self.assertResourceCalled('HdfsResource', None,
|
|
|
+ security_enabled = True,
|
|
|
+ hadoop_bin_dir = '/usr/bin',
|
|
|
+ keytab = '/etc/security/keytabs/hdfs.headless.keytab',
|
|
|
+ hadoop_fs = 'hdfs://c6401.ambari.apache.org:8020',
|
|
|
+ kinit_path_local = '/usr/bin/kinit',
|
|
|
+ user = 'hdfs',
|
|
|
+ action = ['execute'],
|
|
|
+ hadoop_conf_dir = '/etc/hadoop/conf',
|
|
|
+ )
|
|
|
self.assertNoMoreResources()
|
|
|
|
|
|
def test_stop_secured(self):
|
|
@@ -323,37 +330,41 @@ class TestNamenode(RMFTestCase):
|
|
|
user = 'hdfs',
|
|
|
try_sleep = 10,
|
|
|
)
|
|
|
- self.assertResourceCalled('HdfsDirectory', '/tmp',
|
|
|
- security_enabled = False,
|
|
|
- keytab = UnknownConfigurationMock(),
|
|
|
- conf_dir = '/etc/hadoop/conf',
|
|
|
- hdfs_user = 'hdfs',
|
|
|
- kinit_path_local = '/usr/bin/kinit',
|
|
|
- mode = 0777,
|
|
|
- owner = 'hdfs',
|
|
|
- bin_dir = '/usr/bin',
|
|
|
- action = ['create_delayed'],
|
|
|
- )
|
|
|
- self.assertResourceCalled('HdfsDirectory', '/user/ambari-qa',
|
|
|
- security_enabled = False,
|
|
|
- keytab = UnknownConfigurationMock(),
|
|
|
- conf_dir = '/etc/hadoop/conf',
|
|
|
- hdfs_user = 'hdfs',
|
|
|
- kinit_path_local = '/usr/bin/kinit',
|
|
|
- mode = 0770,
|
|
|
- owner = 'ambari-qa',
|
|
|
- bin_dir = '/usr/bin',
|
|
|
- action = ['create_delayed'],
|
|
|
- )
|
|
|
- self.assertResourceCalled('HdfsDirectory', None,
|
|
|
+ self.assertResourceCalled('HdfsResource', '/tmp',
|
|
|
security_enabled = False,
|
|
|
+ hadoop_conf_dir = '/etc/hadoop/conf',
|
|
|
keytab = UnknownConfigurationMock(),
|
|
|
- conf_dir = '/etc/hadoop/conf',
|
|
|
- hdfs_user = 'hdfs',
|
|
|
+ hadoop_fs = 'hdfs://ns1',
|
|
|
kinit_path_local = '/usr/bin/kinit',
|
|
|
- action = ['create'],
|
|
|
- bin_dir = '/usr/bin',
|
|
|
- only_if = "/usr/bin/sudo su hdfs -l -s /bin/bash -c 'export PATH=/bin:/usr/bin ; hdfs --config /etc/hadoop/conf haadmin -getServiceState nn1 | grep active'",
|
|
|
+ user = 'hdfs',
|
|
|
+ owner = 'hdfs',
|
|
|
+ hadoop_bin_dir = '/usr/bin',
|
|
|
+ type = 'directory',
|
|
|
+ action = ['create_delayed'],
|
|
|
+ mode = 0777,
|
|
|
+ )
|
|
|
+ self.assertResourceCalled('HdfsResource', '/user/ambari-qa',
|
|
|
+ security_enabled = False,
|
|
|
+ hadoop_conf_dir = '/etc/hadoop/conf',
|
|
|
+ keytab = UnknownConfigurationMock(),
|
|
|
+ hadoop_fs = 'hdfs://ns1',
|
|
|
+ kinit_path_local = '/usr/bin/kinit',
|
|
|
+ user = 'hdfs',
|
|
|
+ owner = 'ambari-qa',
|
|
|
+ hadoop_bin_dir = '/usr/bin',
|
|
|
+ type = 'directory',
|
|
|
+ action = ['create_delayed'],
|
|
|
+ mode = 0770,
|
|
|
+ )
|
|
|
+ self.assertResourceCalled('HdfsResource', None,
|
|
|
+ security_enabled = False,
|
|
|
+ hadoop_bin_dir = '/usr/bin',
|
|
|
+ keytab = UnknownConfigurationMock(),
|
|
|
+ hadoop_fs = 'hdfs://ns1',
|
|
|
+ kinit_path_local = '/usr/bin/kinit',
|
|
|
+ user = 'hdfs',
|
|
|
+ action = ['execute'],
|
|
|
+ hadoop_conf_dir = '/etc/hadoop/conf',
|
|
|
)
|
|
|
self.assertNoMoreResources()
|
|
|
|
|
@@ -402,37 +413,42 @@ class TestNamenode(RMFTestCase):
|
|
|
user = 'hdfs',
|
|
|
try_sleep = 10,
|
|
|
)
|
|
|
- self.assertResourceCalled('HdfsDirectory', '/tmp',
|
|
|
- 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 = 'hdfs',
|
|
|
- bin_dir = '/usr/bin',
|
|
|
- action = ['create_delayed'],
|
|
|
- )
|
|
|
- self.assertResourceCalled('HdfsDirectory', '/user/ambari-qa',
|
|
|
- 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 = 0770,
|
|
|
- owner = 'ambari-qa',
|
|
|
- bin_dir = '/usr/bin',
|
|
|
- action = ['create_delayed'],
|
|
|
- )
|
|
|
- self.assertResourceCalled('HdfsDirectory', None,
|
|
|
+
|
|
|
+ self.assertResourceCalled('HdfsResource', '/tmp',
|
|
|
security_enabled = True,
|
|
|
+ hadoop_conf_dir = '/etc/hadoop/conf',
|
|
|
keytab = '/etc/security/keytabs/hdfs.headless.keytab',
|
|
|
- conf_dir = '/etc/hadoop/conf',
|
|
|
- hdfs_user = 'hdfs',
|
|
|
+ hadoop_fs = 'hdfs://ns1',
|
|
|
kinit_path_local = '/usr/bin/kinit',
|
|
|
- action = ['create'],
|
|
|
- bin_dir = '/usr/bin',
|
|
|
- only_if = "/usr/bin/sudo su hdfs -l -s /bin/bash -c 'export PATH=/bin:/usr/bin ; hdfs --config /etc/hadoop/conf haadmin -getServiceState nn1 | grep active'",
|
|
|
+ user = 'hdfs',
|
|
|
+ owner = 'hdfs',
|
|
|
+ hadoop_bin_dir = '/usr/bin',
|
|
|
+ type = 'directory',
|
|
|
+ action = ['create_delayed'],
|
|
|
+ mode = 0777,
|
|
|
+ )
|
|
|
+ self.assertResourceCalled('HdfsResource', '/user/ambari-qa',
|
|
|
+ security_enabled = True,
|
|
|
+ hadoop_conf_dir = '/etc/hadoop/conf',
|
|
|
+ keytab = '/etc/security/keytabs/hdfs.headless.keytab',
|
|
|
+ hadoop_fs = 'hdfs://ns1',
|
|
|
+ kinit_path_local = '/usr/bin/kinit',
|
|
|
+ user = 'hdfs',
|
|
|
+ owner = 'ambari-qa',
|
|
|
+ hadoop_bin_dir = '/usr/bin',
|
|
|
+ type = 'directory',
|
|
|
+ action = ['create_delayed'],
|
|
|
+ mode = 0770,
|
|
|
+ )
|
|
|
+ self.assertResourceCalled('HdfsResource', None,
|
|
|
+ security_enabled = True,
|
|
|
+ hadoop_bin_dir = '/usr/bin',
|
|
|
+ keytab = '/etc/security/keytabs/hdfs.headless.keytab',
|
|
|
+ hadoop_fs = 'hdfs://ns1',
|
|
|
+ kinit_path_local = '/usr/bin/kinit',
|
|
|
+ user = 'hdfs',
|
|
|
+ action = ['execute'],
|
|
|
+ hadoop_conf_dir = '/etc/hadoop/conf',
|
|
|
)
|
|
|
self.assertNoMoreResources()
|
|
|
|
|
@@ -494,38 +510,42 @@ class TestNamenode(RMFTestCase):
|
|
|
user = 'hdfs',
|
|
|
try_sleep = 10,
|
|
|
)
|
|
|
- self.assertResourceCalled('HdfsDirectory', '/tmp',
|
|
|
- security_enabled = False,
|
|
|
- keytab = UnknownConfigurationMock(),
|
|
|
- conf_dir = '/etc/hadoop/conf',
|
|
|
- hdfs_user = 'hdfs',
|
|
|
- kinit_path_local = '/usr/bin/kinit',
|
|
|
- mode = 0777,
|
|
|
- owner = 'hdfs',
|
|
|
- bin_dir = '/usr/bin',
|
|
|
- action = ['create_delayed'],
|
|
|
- )
|
|
|
- self.assertResourceCalled('HdfsDirectory', '/user/ambari-qa',
|
|
|
- security_enabled = False,
|
|
|
- keytab = UnknownConfigurationMock(),
|
|
|
- conf_dir = '/etc/hadoop/conf',
|
|
|
- hdfs_user = 'hdfs',
|
|
|
- kinit_path_local = '/usr/bin/kinit',
|
|
|
- mode = 0770,
|
|
|
- owner = 'ambari-qa',
|
|
|
- bin_dir = '/usr/bin',
|
|
|
- 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'],
|
|
|
- bin_dir = '/usr/bin',
|
|
|
- only_if = "/usr/bin/sudo su hdfs -l -s /bin/bash -c 'export PATH=/bin:/usr/bin ; hdfs --config /etc/hadoop/conf haadmin -getServiceState nn1 | grep active'",
|
|
|
- )
|
|
|
+ self.assertResourceCalled('HdfsResource', '/tmp',
|
|
|
+ security_enabled = False,
|
|
|
+ hadoop_conf_dir = '/etc/hadoop/conf',
|
|
|
+ keytab = UnknownConfigurationMock(),
|
|
|
+ hadoop_fs = 'hdfs://ns1',
|
|
|
+ kinit_path_local = '/usr/bin/kinit',
|
|
|
+ user = 'hdfs',
|
|
|
+ owner = 'hdfs',
|
|
|
+ hadoop_bin_dir = '/usr/bin',
|
|
|
+ type = 'directory',
|
|
|
+ action = ['create_delayed'],
|
|
|
+ mode = 0777,
|
|
|
+ )
|
|
|
+ self.assertResourceCalled('HdfsResource', '/user/ambari-qa',
|
|
|
+ security_enabled = False,
|
|
|
+ hadoop_conf_dir = '/etc/hadoop/conf',
|
|
|
+ keytab = UnknownConfigurationMock(),
|
|
|
+ hadoop_fs = 'hdfs://ns1',
|
|
|
+ kinit_path_local = '/usr/bin/kinit',
|
|
|
+ user = 'hdfs',
|
|
|
+ owner = 'ambari-qa',
|
|
|
+ hadoop_bin_dir = '/usr/bin',
|
|
|
+ type = 'directory',
|
|
|
+ action = ['create_delayed'],
|
|
|
+ mode = 0770,
|
|
|
+ )
|
|
|
+ self.assertResourceCalled('HdfsResource', None,
|
|
|
+ security_enabled = False,
|
|
|
+ hadoop_bin_dir = '/usr/bin',
|
|
|
+ keytab = UnknownConfigurationMock(),
|
|
|
+ hadoop_fs = 'hdfs://ns1',
|
|
|
+ kinit_path_local = '/usr/bin/kinit',
|
|
|
+ user = 'hdfs',
|
|
|
+ action = ['execute'],
|
|
|
+ hadoop_conf_dir = '/etc/hadoop/conf',
|
|
|
+ )
|
|
|
self.assertNoMoreResources()
|
|
|
|
|
|
# tests namenode start command when NameNode HA is enabled, and
|
|
@@ -574,44 +594,48 @@ class TestNamenode(RMFTestCase):
|
|
|
not_if = 'ls /var/run/hadoop/hdfs/hadoop-hdfs-namenode.pid >/dev/null 2>&1 && ps -p `cat /var/run/hadoop/hdfs/hadoop-hdfs-namenode.pid` >/dev/null 2>&1',
|
|
|
)
|
|
|
self.assertResourceCalled('Execute', "hadoop dfsadmin -safemode get | grep 'Safe mode is OFF'",
|
|
|
- path = ['/usr/bin'],
|
|
|
- tries = 40,
|
|
|
- only_if = "/usr/bin/sudo su hdfs -l -s /bin/bash -c 'export PATH=/bin:/usr/bin ; hdfs --config /etc/hadoop/conf haadmin -getServiceState nn2 | grep active'",
|
|
|
- user = 'hdfs',
|
|
|
- try_sleep = 10,
|
|
|
- )
|
|
|
- self.assertResourceCalled('HdfsDirectory', '/tmp',
|
|
|
- security_enabled = False,
|
|
|
- keytab = UnknownConfigurationMock(),
|
|
|
- conf_dir = '/etc/hadoop/conf',
|
|
|
- hdfs_user = 'hdfs',
|
|
|
- kinit_path_local = '/usr/bin/kinit',
|
|
|
- mode = 0777,
|
|
|
- owner = 'hdfs',
|
|
|
- bin_dir = '/usr/bin',
|
|
|
- action = ['create_delayed'],
|
|
|
- )
|
|
|
- self.assertResourceCalled('HdfsDirectory', '/user/ambari-qa',
|
|
|
- security_enabled = False,
|
|
|
- keytab = UnknownConfigurationMock(),
|
|
|
- conf_dir = '/etc/hadoop/conf',
|
|
|
- hdfs_user = 'hdfs',
|
|
|
- kinit_path_local = '/usr/bin/kinit',
|
|
|
- mode = 0770,
|
|
|
- owner = 'ambari-qa',
|
|
|
- bin_dir = '/usr/bin',
|
|
|
- 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'],
|
|
|
- bin_dir = '/usr/bin',
|
|
|
- only_if = "/usr/bin/sudo su hdfs -l -s /bin/bash -c 'export PATH=/bin:/usr/bin ; hdfs --config /etc/hadoop/conf haadmin -getServiceState nn2 | grep active'",
|
|
|
- )
|
|
|
+ path = ['/usr/bin'],
|
|
|
+ tries = 40,
|
|
|
+ only_if = "/usr/bin/sudo su hdfs -l -s /bin/bash -c 'export PATH=/bin:/usr/bin ; hdfs --config /etc/hadoop/conf haadmin -getServiceState nn2 | grep active'",
|
|
|
+ user = 'hdfs',
|
|
|
+ try_sleep = 10,
|
|
|
+ )
|
|
|
+ self.assertResourceCalled('HdfsResource', '/tmp',
|
|
|
+ security_enabled = False,
|
|
|
+ hadoop_conf_dir = '/etc/hadoop/conf',
|
|
|
+ keytab = UnknownConfigurationMock(),
|
|
|
+ hadoop_fs = 'hdfs://ns1',
|
|
|
+ kinit_path_local = '/usr/bin/kinit',
|
|
|
+ user = 'hdfs',
|
|
|
+ owner = 'hdfs',
|
|
|
+ hadoop_bin_dir = '/usr/bin',
|
|
|
+ type = 'directory',
|
|
|
+ action = ['create_delayed'],
|
|
|
+ mode = 0777,
|
|
|
+ )
|
|
|
+ self.assertResourceCalled('HdfsResource', '/user/ambari-qa',
|
|
|
+ security_enabled = False,
|
|
|
+ hadoop_conf_dir = '/etc/hadoop/conf',
|
|
|
+ keytab = UnknownConfigurationMock(),
|
|
|
+ hadoop_fs = 'hdfs://ns1',
|
|
|
+ kinit_path_local = '/usr/bin/kinit',
|
|
|
+ user = 'hdfs',
|
|
|
+ owner = 'ambari-qa',
|
|
|
+ hadoop_bin_dir = '/usr/bin',
|
|
|
+ type = 'directory',
|
|
|
+ action = ['create_delayed'],
|
|
|
+ mode = 0770,
|
|
|
+ )
|
|
|
+ self.assertResourceCalled('HdfsResource', None,
|
|
|
+ security_enabled = False,
|
|
|
+ hadoop_bin_dir = '/usr/bin',
|
|
|
+ keytab = UnknownConfigurationMock(),
|
|
|
+ hadoop_fs = 'hdfs://ns1',
|
|
|
+ kinit_path_local = '/usr/bin/kinit',
|
|
|
+ user = 'hdfs',
|
|
|
+ action = ['execute'],
|
|
|
+ hadoop_conf_dir = '/etc/hadoop/conf',
|
|
|
+ )
|
|
|
self.assertNoMoreResources()
|
|
|
|
|
|
def test_decommission_default(self):
|
|
@@ -728,6 +752,9 @@ class TestNamenode(RMFTestCase):
|
|
|
content = Template('slaves.j2'),
|
|
|
owner = 'hdfs',
|
|
|
)
|
|
|
+ self.assertResourceCalled('File', '/var/lib/ambari-agent/lib/fast-hdfs-resource.jar',
|
|
|
+ content = StaticFile('fast-hdfs-resource.jar'),
|
|
|
+ )
|
|
|
self.assertResourceCalled('Directory', '/hadoop/hdfs/namenode',
|
|
|
owner = 'hdfs',
|
|
|
group = 'hadoop',
|
|
@@ -767,6 +794,9 @@ class TestNamenode(RMFTestCase):
|
|
|
content = Template('slaves.j2'),
|
|
|
owner = 'root',
|
|
|
)
|
|
|
+ self.assertResourceCalled('File', '/var/lib/ambari-agent/lib/fast-hdfs-resource.jar',
|
|
|
+ content = StaticFile('fast-hdfs-resource.jar'),
|
|
|
+ )
|
|
|
self.assertResourceCalled('Directory', '/hadoop/hdfs/namenode',
|
|
|
owner = 'hdfs',
|
|
|
group = 'hadoop',
|