This is an automated email from the ASF dual-hosted git repository. bereng 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 c67b12d Flaky TestPaxos.test_replica_availability c67b12d is described below commit c67b12d14d75a70336b7b7fef8d4f81d80e32124 Author: Bereng <berenguerbl...@gmail.com> AuthorDate: Tue May 25 08:46:07 2021 +0200 Flaky TestPaxos.test_replica_availability patch by Berenguer Blasi; reviewed by Ekaterina Dimitrova for CASSANDRA-16693 --- paxos_test.py | 11 +++++++---- 1 file changed, 7 insertions(+), 4 deletions(-) diff --git a/paxos_test.py b/paxos_test.py index 457b74f..5265be4 100644 --- a/paxos_test.py +++ b/paxos_test.py @@ -48,16 +48,19 @@ class TestPaxos(Tester): session.execute("CREATE TABLE test (k int PRIMARY KEY, v int)") session.execute("INSERT INTO test (k, v) VALUES (0, 0) IF NOT EXISTS") - self.cluster.nodelist()[2].stop() + node1 = self.cluster.nodelist()[1] + node2 = self.cluster.nodelist()[2] + + node2.stop() session.execute("INSERT INTO test (k, v) VALUES (1, 1) IF NOT EXISTS") - self.cluster.nodelist()[1].stop() + node1.stop() assert_unavailable(session.execute, "INSERT INTO test (k, v) VALUES (2, 2) IF NOT EXISTS") - self.cluster.nodelist()[1].start() + node1.start(wait_for_binary_proto=True) session.execute("INSERT INTO test (k, v) VALUES (3, 3) IF NOT EXISTS") - self.cluster.nodelist()[2].start() + node2.start(wait_for_binary_proto=True) session.execute("INSERT INTO test (k, v) VALUES (4, 4) IF NOT EXISTS") @pytest.mark.no_vnodes --------------------------------------------------------------------- To unsubscribe, e-mail: commits-unsubscr...@cassandra.apache.org For additional commands, e-mail: commits-h...@cassandra.apache.org