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