You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@cassandra.apache.org by mc...@apache.org on 2021/02/19 16:36:53 UTC
[cassandra-dtest] branch trunk updated: Add explicit DC to tests
where we have multidc setup
This is an automated email from the ASF dual-hosted git repository.
mck pushed a commit to branch trunk
in repository https://gitbox.apache.org/repos/asf/cassandra-dtest.git
The following commit(s) were added to refs/heads/trunk by this push:
new 8762267 Add explicit DC to tests where we have multidc setup
8762267 is described below
commit 8762267b13fffb921ae79b0220630f10695ee9d9
Author: Bereng <be...@gmail.com>
AuthorDate: Mon Feb 15 08:13:22 2021 +0100
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
---
disk_balance_test.py | 2 +-
materialized_views_test.py | 8 ++++----
2 files changed, 5 insertions(+), 5 deletions(-)
diff --git a/disk_balance_test.py b/disk_balance_test.py
index 9ab22b2..ceadf98 100644
--- a/disk_balance_test.py
+++ b/disk_balance_test.py
@@ -60,7 +60,7 @@ class TestDiskBalance(Tester):
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)
diff --git a/materialized_views_test.py b/materialized_views_test.py
index 3143a01..5bd0d5f 100644
--- a/materialized_views_test.py
+++ b/materialized_views_test.py
@@ -602,7 +602,7 @@ class TestMaterializedViews(Tester):
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 @@ class TestMaterializedViews(Tester):
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 @@ class TestMaterializedViews(Tester):
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 @@ class TestMaterializedViews(Tester):
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):
---------------------------------------------------------------------
To unsubscribe, e-mail: commits-unsubscribe@cassandra.apache.org
For additional commands, e-mail: commits-help@cassandra.apache.org