|
@@ -88,6 +88,7 @@ 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',
|
|
@@ -99,43 +100,38 @@ class TestNamenode(RMFTestCase):
|
|
|
user = 'hdfs',
|
|
|
try_sleep = 10,
|
|
|
)
|
|
|
- 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',
|
|
|
- only_if= None,
|
|
|
- )
|
|
|
+ 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.assertNoMoreResources()
|
|
|
|
|
|
def test_stop_default(self):
|
|
@@ -230,43 +226,38 @@ class TestNamenode(RMFTestCase):
|
|
|
user = 'hdfs',
|
|
|
try_sleep = 10,
|
|
|
)
|
|
|
- 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,
|
|
|
- only_if = None,
|
|
|
- keytab = '/etc/security/keytabs/hdfs.headless.keytab',
|
|
|
- hadoop_bin_dir = '/usr/bin',
|
|
|
- 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.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.assertNoMoreResources()
|
|
|
|
|
|
def test_stop_secured(self):
|
|
@@ -332,42 +323,37 @@ class TestNamenode(RMFTestCase):
|
|
|
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',
|
|
|
+ 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,
|
|
|
- hadoop_conf_dir = '/etc/hadoop/conf',
|
|
|
keytab = UnknownConfigurationMock(),
|
|
|
- hadoop_fs = 'hdfs://ns1',
|
|
|
+ conf_dir = '/etc/hadoop/conf',
|
|
|
+ hdfs_user = 'hdfs',
|
|
|
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,
|
|
|
+ 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'",
|
|
|
- keytab = UnknownConfigurationMock(),
|
|
|
- hadoop_bin_dir = '/usr/bin',
|
|
|
- hadoop_fs = 'hdfs://ns1',
|
|
|
- kinit_path_local = '/usr/bin/kinit',
|
|
|
- user = 'hdfs',
|
|
|
- action = ['execute'],
|
|
|
- hadoop_conf_dir = '/etc/hadoop/conf',
|
|
|
)
|
|
|
self.assertNoMoreResources()
|
|
|
|
|
@@ -416,43 +402,37 @@ class TestNamenode(RMFTestCase):
|
|
|
user = 'hdfs',
|
|
|
try_sleep = 10,
|
|
|
)
|
|
|
-
|
|
|
- self.assertResourceCalled('HdfsResource', '/tmp',
|
|
|
- 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 = 'hdfs',
|
|
|
- hadoop_bin_dir = '/usr/bin',
|
|
|
- type = 'directory',
|
|
|
- action = ['create_delayed'],
|
|
|
- mode = 0777,
|
|
|
- )
|
|
|
- self.assertResourceCalled('HdfsResource', '/user/ambari-qa',
|
|
|
+ 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,
|
|
|
- hadoop_conf_dir = '/etc/hadoop/conf',
|
|
|
keytab = '/etc/security/keytabs/hdfs.headless.keytab',
|
|
|
- hadoop_fs = 'hdfs://ns1',
|
|
|
+ conf_dir = '/etc/hadoop/conf',
|
|
|
+ hdfs_user = 'hdfs',
|
|
|
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,
|
|
|
+ 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'",
|
|
|
- keytab = '/etc/security/keytabs/hdfs.headless.keytab',
|
|
|
- hadoop_bin_dir = '/usr/bin',
|
|
|
- hadoop_fs = 'hdfs://ns1',
|
|
|
- kinit_path_local = '/usr/bin/kinit',
|
|
|
- user = 'hdfs',
|
|
|
- action = ['execute'],
|
|
|
- hadoop_conf_dir = '/etc/hadoop/conf',
|
|
|
)
|
|
|
self.assertNoMoreResources()
|
|
|
|
|
@@ -514,43 +494,38 @@ class TestNamenode(RMFTestCase):
|
|
|
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',
|
|
|
- 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('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.assertNoMoreResources()
|
|
|
|
|
|
# tests namenode start command when NameNode HA is enabled, and
|
|
@@ -599,49 +574,44 @@ 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('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,
|
|
|
- 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'",
|
|
|
- keytab = UnknownConfigurationMock(),
|
|
|
- hadoop_bin_dir = '/usr/bin',
|
|
|
- hadoop_fs = 'hdfs://ns1',
|
|
|
- kinit_path_local = '/usr/bin/kinit',
|
|
|
- user = 'hdfs',
|
|
|
- action = ['execute'],
|
|
|
- hadoop_conf_dir = '/etc/hadoop/conf',
|
|
|
- )
|
|
|
+ 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'",
|
|
|
+ )
|
|
|
self.assertNoMoreResources()
|
|
|
|
|
|
def test_decommission_default(self):
|
|
@@ -758,9 +728,6 @@ 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',
|
|
@@ -800,9 +767,6 @@ 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',
|