You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@cassandra.apache.org by ed...@apache.org on 2021/05/19 13:16:17 UTC
[cassandra-dtest] branch trunk updated: Fix
paxos_test::test_cluster_availability authored by Ekaterina Dimitrova;
reviewed by Berenguer Blasi for CASSANDRA-16657
This is an automated email from the ASF dual-hosted git repository.
edimitrova 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 e94e930 Fix paxos_test::test_cluster_availability authored by Ekaterina Dimitrova; reviewed by Berenguer Blasi for CASSANDRA-16657
e94e930 is described below
commit e94e930d2c1de6b7b6824d163e0c42f6b96ba492
Author: Ekaterina Dimitrova <ek...@datastax.com>
AuthorDate: Mon May 17 19:53:04 2021 -0400
Fix paxos_test::test_cluster_availability
authored by Ekaterina Dimitrova; reviewed by Berenguer Blasi for CASSANDRA-16657
---
paxos_test.py | 10 ++++++----
1 file changed, 6 insertions(+), 4 deletions(-)
diff --git a/paxos_test.py b/paxos_test.py
index 6d03654..457b74f 100644
--- a/paxos_test.py
+++ b/paxos_test.py
@@ -67,19 +67,21 @@ class TestPaxos(Tester):
# This must not use vnodes as it relies on assumed token values.
session = self.prepare(nodes=3)
+ node2 = self.cluster.nodelist()[1]
+ node3 = self.cluster.nodelist()[2]
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()
+ node3.stop()
session.execute("INSERT INTO test (k, v) VALUES (1, 1) IF NOT EXISTS")
- self.cluster.nodelist()[1].stop()
+ node2.stop()
session.execute("INSERT INTO test (k, v) VALUES (3, 2) IF NOT EXISTS")
- self.cluster.nodelist()[1].start()
+ node2.start(wait_for_binary_proto = True)
session.execute("INSERT INTO test (k, v) VALUES (5, 5) IF NOT EXISTS")
- self.cluster.nodelist()[2].start()
+ node3.start(wait_for_binary_proto = True)
session.execute("INSERT INTO test (k, v) VALUES (6, 6) IF NOT EXISTS")
def test_contention_multi_iterations(self):
---------------------------------------------------------------------
To unsubscribe, e-mail: commits-unsubscribe@cassandra.apache.org
For additional commands, e-mail: commits-help@cassandra.apache.org