Skip to content
Permalink
Browse files
Add explicit DC to tests where we have multidc setup
 patch by Berenguer Blasi; reviewed by Ekaterina Dimitrova, Tomek Łasica, Andres de la Peña for CASSANDRA-16411
  • Loading branch information
bereng authored and michaelsembwever committed Feb 19, 2021
1 parent 493ddae commit 8762267b13fffb921ae79b0220630f10695ee9d9
Show file tree
Hide file tree
Showing 2 changed files with 5 additions and 5 deletions.
@@ -60,7 +60,7 @@ def test_disk_balance_bootstrap(self):
node1.stress(['write', 'n=50k', 'no-warmup', '-rate', 'threads=100', '-schema', 'replication(factor=3)',
'compaction(strategy=SizeTieredCompactionStrategy,enabled=false)'])
cluster.flush()
node5 = new_node(cluster)
node5 = new_node(cluster, data_center="dc1")
node5.start(wait_for_binary_proto=True)
self.assert_balanced(node5)

@@ -602,7 +602,7 @@ def test_add_node_after_mv(self):
for i in range(1000):
assert_one(session, "SELECT * FROM t_by_v WHERE v = {}".format(-i), [-i, i])

node4 = new_node(self.cluster)
node4 = new_node(self.cluster, data_center="dc1")
node4.start(wait_for_binary_proto=True, jvm_args=["-Dcassandra.migration_task_wait_in_seconds={}".format(MIGRATION_WAIT)])

session2 = self.patient_exclusive_cql_connection(node4)
@@ -711,7 +711,7 @@ def test_add_node_after_wide_mv_with_range_deletions(self):
assert_one(session, "SELECT * FROM t WHERE id = {} and v = {}".format(i, j), [i, j])
assert_one(session, "SELECT * FROM t_by_v WHERE id = {} and v = {}".format(i, j), [j, i])

node4 = new_node(self.cluster)
node4 = new_node(self.cluster, data_center="dc1")
node4.set_configuration_options(values={'max_mutation_size_in_kb': 20}) # CASSANDRA-11670
logger.debug("Start join at {}".format(time.strftime("%H:%M:%S")))
node4.start(wait_for_binary_proto=True, jvm_args=["-Dcassandra.migration_task_wait_in_seconds={}".format(MIGRATION_WAIT)])
@@ -764,7 +764,7 @@ def test_add_node_after_very_wide_mv(self):
for j in range(5000):
assert_one(session, "SELECT * FROM t_by_v WHERE id = {} and v = {}".format(i, j), [j, i])

node4 = new_node(self.cluster)
node4 = new_node(self.cluster, data_center="dc1")
node4.set_configuration_options(values={'max_mutation_size_in_kb': 20}) # CASSANDRA-11670
logger.debug("Start join at {}".format(time.strftime("%H:%M:%S")))
node4.start(wait_for_binary_proto=True, jvm_args=["-Dcassandra.migration_task_wait_in_seconds={}".format(MIGRATION_WAIT)])
@@ -804,7 +804,7 @@ def test_add_write_survey_node_after_mv(self):
for i in range(1000):
assert_one(session, "SELECT * FROM t_by_v WHERE v = {}".format(-i), [-i, i])

node4 = new_node(self.cluster)
node4 = new_node(self.cluster, data_center="dc1")
node4.start(wait_for_binary_proto=True, jvm_args=["-Dcassandra.write_survey=true", "-Dcassandra.migration_task_wait_in_seconds={}".format(MIGRATION_WAIT)])

for i in range(1000, 1100):

0 comments on commit 8762267

Please sign in to comment.