You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@cassandra.apache.org by br...@apache.org on 2021/03/04 19:59:50 UTC
[cassandra-dtest] 01/02: add simple removenode test
This is an automated email from the ASF dual-hosted git repository.
brandonwilliams pushed a commit to branch trunk
in repository https://gitbox.apache.org/repos/asf/cassandra-dtest.git
commit c439ff0ea34d37b1c799e7e54e48102caee7805e
Author: Brandon Williams <br...@apache.org>
AuthorDate: Mon Feb 1 17:47:54 2021 -0600
add simple removenode test
Patch by brandonwilliams; reviwed by mck for CASSANDRA-16381
---
topology_test.py | 15 +++++++++++++++
1 file changed, 15 insertions(+)
diff --git a/topology_test.py b/topology_test.py
index 6da9b7c..10b73c9 100644
--- a/topology_test.py
+++ b/topology_test.py
@@ -127,6 +127,21 @@ class TestTopology(Tester):
assert_none(session, "SELECT range_start, range_end FROM system.size_estimates "
"WHERE keyspace_name = 'ks2'")
+ def test_simple_removenode(self):
+ """ test removenode """
+ cluster = self.cluster
+ cluster.populate(3)
+ cluster.start(jvm_args=["-Dcassandra.size_recorder_interval=1"])
+ node1, node2, node3 = cluster.nodelist()
+
+ node1.stress(['write', 'n=10K', 'no-warmup', '-rate', 'threads=8', '-schema', 'replication(factor=2)'])
+
+ node3_id = node3.nodetool('info').stdout[25:61]
+ node3.stop(wait_other_notice=True)
+ node1.nodetool('removenode ' + node3_id)
+
+ node1.stress(['read', 'n=10K', 'no-warmup', '-rate', 'threads=8'])
+
def test_simple_decommission(self):
"""
@jira_ticket CASSANDRA-9912
---------------------------------------------------------------------
To unsubscribe, e-mail: commits-unsubscribe@cassandra.apache.org
For additional commands, e-mail: commits-help@cassandra.apache.org