You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@cassandra.apache.org by sa...@apache.org on 2023/11/24 10:44:42 UTC
(cassandra-dtest) 09/37: [CEP-21] Fix topology_test
This is an automated email from the ASF dual-hosted git repository.
samt pushed a commit to branch trunk
in repository https://gitbox.apache.org/repos/asf/cassandra-dtest.git
commit d401b1ebb0ab3d1d2a4baea5acf5e42713def963
Author: Sam Tunnicliffe <sa...@apple.com>
AuthorDate: Wed Aug 30 16:07:58 2023 +0100
[CEP-21] Fix topology_test
---
topology_test.py | 18 +++++++++---------
1 file changed, 9 insertions(+), 9 deletions(-)
diff --git a/topology_test.py b/topology_test.py
index 3421c363..e1b89082 100644
--- a/topology_test.py
+++ b/topology_test.py
@@ -448,31 +448,31 @@ class TestTopology(Tester):
self.fixture_dtest_setup.ignore_log_patterns = [r'Streaming error occurred', 'Stream failed']
cluster.populate(3).start()
- node1, node2 = cluster.nodelist()[0:2]
+ node1, node2, node3 = cluster.nodelist()[0:3]
session = self.patient_cql_connection(node1)
session.execute("ALTER KEYSPACE system_distributed WITH REPLICATION = {'class':'SimpleStrategy', 'replication_factor':'2'};")
- t = DecommissionInParallel(node1)
+ t = DecommissionInParallel(node2)
t.start()
- node1.watch_log_for("DECOMMISSIONING", filename='debug.log')
+ node2.watch_log_for("DECOMMISSIONING", filename='debug.log')
null_status_pattern = re.compile(r".N(?:\s*)127\.0\.0\.1(?:.*)null(?:\s*)rack1")
while t.is_alive():
- out = self.show_status(node2)
+ out = self.show_status(node3)
if null_status_pattern.search(out):
logger.debug("Matched null status entry")
break
- logger.debug("Restarting node2")
- node2.stop(gently=False)
- node2.start(wait_for_binary_proto=True, wait_other_notice=False)
+ logger.debug("Restarting node3")
+ node3.stop(gently=False)
+ node3.start(wait_for_binary_proto=True, wait_other_notice=False)
logger.debug("Waiting for decommission to complete")
t.join()
- self.show_status(node2)
+ self.show_status(node3)
logger.debug("Sleeping for 30 seconds to allow gossip updates")
time.sleep(30)
- out = self.show_status(node2)
+ out = self.show_status(node3)
assert not null_status_pattern.search(out)
@since('3.12')
---------------------------------------------------------------------
To unsubscribe, e-mail: commits-unsubscribe@cassandra.apache.org
For additional commands, e-mail: commits-help@cassandra.apache.org