Add integration tests for scaling in Spark

Spark scaling cluster was fixed, so we need to add scaling integration
test

Closes-bug: #1433064
Change-Id: I8b5d50786507d418620973401b11b2a76a8becc0
This commit is contained in:
luhuichun 2015-03-19 06:30:56 +08:00
parent 8f89aa16db
commit 0f22fdb18f
1 changed files with 18 additions and 3 deletions

View File

@ -127,12 +127,27 @@ class SparkGatingTest(swift.SwiftTest, scaling.ScalingTest,
@b.errormsg("Failure while cluster scaling: ")
def _check_scaling(self):
pass
change_list = [
{
'operation': 'resize',
'info': ['worker-node', 2]
},
{
'operation': 'add',
'info': [
'new-worker-node', 1, '%s' % self.ng_tmpl_s_dn_id
]
}
]
self.cluster_info = self.cluster_scaling(self.cluster_info,
change_list)
self.await_active_workers_for_namenode(self.cluster_info['node_info'],
self.plugin_config)
@b.errormsg("Failure while EDP testing after cluster scaling: ")
def _check_edp_after_scaling(self):
# Leave this blank until scaling is implemented
pass
self._check_edp()
@testcase.attr('spark')
@testcase.skipIf(config.SKIP_ALL_TESTS_FOR_PLUGIN,