Skip to content
Permalink
Browse files
Flaky TestTransientReplicationRing.test_move_backwards_and_cleanup
patch by Berenguer Blasi; reviewed by Ekaterina Dimitrova for CASSANDRA-16644
  • Loading branch information
bereng committed May 17, 2021
1 parent 2e9fca9 commit a3b24d7617bff1eb9aa1a30474f09b211ea4c1db
Showing 1 changed file with 5 additions and 5 deletions.
@@ -3,7 +3,9 @@

from cassandra import ConsistencyLevel
from cassandra.query import SimpleStatement
from ccmlib.cluster import DEFAULT_CLUSTER_WAIT_TIMEOUT_IN_SECS
from ccmlib.node import Node
from ccmlib.node import NODE_WAIT_TIMEOUT_IN_SECS

from dtest import Tester
from tools.assertions import (assert_all)
@@ -116,7 +118,8 @@ def setup_cluster(self, fixture_dtest_setup):
print(self.cluster.get_install_dir())
self.cluster.populate(3, tokens=self.tokens, debug=True, install_byteman=True)
# self.cluster.populate(3, debug=True, install_byteman=True)
self.cluster.start(jvm_args=['-Dcassandra.enable_nodelocal_queries=true'])
self.cluster.start(jvm_args=['-Dcassandra.enable_nodelocal_queries=true'],
timeout=DEFAULT_CLUSTER_WAIT_TIMEOUT_IN_SECS * 2)

# enable shared memory
for node in self.cluster.nodelist():
@@ -226,13 +229,12 @@ def test_bootstrap_and_cleanup(self):
# Every value should be replicated exactly 2 times
self.check_replication(sessions, exactly=2)

@flaky(max_runs=1)
@pytest.mark.no_vnodes
def move_test(self, move_token, expected_after_move, expected_after_repair):
"""Helper method to run a move test cycle"""
node4 = new_node(self.cluster, bootstrap=True, token='00040')
patch_start(node4)
node4.start(wait_for_binary_proto=True)
node4.start(wait_for_binary_proto=NODE_WAIT_TIMEOUT_IN_SECS * 2)
main_session = self.patient_cql_connection(self.node1)
nodes = [self.node1, self.node2, self.node3, node4]

@@ -392,7 +394,6 @@ def test_decommission(self):
self.check_expected(sessions, expected, nodes, cleanup=True)
self.check_replication(sessions, exactly=2)

@flaky(max_runs=1)
@pytest.mark.no_vnodes
def test_remove(self):
"""Test a mix of ring change operations across a mix of transient and repaired/unrepaired data"""
@@ -432,7 +433,6 @@ def test_remove(self):

self._nodes_have_proper_ranges_after_repair_and_cleanup(sessions)

@flaky(max_runs=1)
@pytest.mark.no_vnodes
def test_replace(self):
main_session = self.patient_cql_connection(self.node1)

0 comments on commit a3b24d7

Please sign in to comment.