cassandra-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From pa...@apache.org
Subject [04/50] cassandra git commit: adding test for repair preview introduced in CASSANDRA-13257 (#1465)
Date Tue, 05 Sep 2017 06:05:18 GMT
adding test for repair preview introduced in CASSANDRA-13257 (#1465)

* adding test for repair preview

* review fixes


Project: http://git-wip-us.apache.org/repos/asf/cassandra/repo
Commit: http://git-wip-us.apache.org/repos/asf/cassandra/commit/d5c413c4
Tree: http://git-wip-us.apache.org/repos/asf/cassandra/tree/d5c413c4
Diff: http://git-wip-us.apache.org/repos/asf/cassandra/diff/d5c413c4

Branch: refs/heads/master
Commit: d5c413c41ba174276196a8b7c5f590632c5e20be
Parents: 0667de0
Author: Blake Eggleston <bdeggleston@gmail.com>
Authored: Tue May 9 12:45:10 2017 -0700
Committer: Philip Thompson <ptnapoleon@gmail.com>
Committed: Tue May 9 15:45:10 2017 -0400

----------------------------------------------------------------------
 repair_tests/preview_repair_test.py | 85 ++++++++++++++++++++++++++++++++
 1 file changed, 85 insertions(+)
----------------------------------------------------------------------


http://git-wip-us.apache.org/repos/asf/cassandra/blob/d5c413c4/repair_tests/preview_repair_test.py
----------------------------------------------------------------------
diff --git a/repair_tests/preview_repair_test.py b/repair_tests/preview_repair_test.py
new file mode 100644
index 0000000..e888a9b
--- /dev/null
+++ b/repair_tests/preview_repair_test.py
@@ -0,0 +1,85 @@
+import time
+
+from cassandra import ConsistencyLevel
+from cassandra.query import SimpleStatement
+
+from dtest import Tester
+from tools.decorators import no_vnodes
+
+
+class PreviewRepairTest(Tester):
+
+    def assert_no_repair_history(self, session):
+        rows = session.execute("select * from system_distributed.repair_history")
+        self.assertEqual(rows.current_rows, [])
+        rows = session.execute("select * from system_distributed.parent_repair_history")
+        self.assertEqual(rows.current_rows, [])
+
+    @no_vnodes()
+    def preview_test(self):
+        """ Test that preview correctly detects out of sync data """
+        cluster = self.cluster
+        cluster.set_configuration_options(values={'hinted_handoff_enabled': False, 'commitlog_sync_period_in_ms':
500})
+        cluster.populate(3).start()
+        node1, node2, node3 = cluster.nodelist()
+
+        session = self.patient_exclusive_cql_connection(node3)
+        session.execute("CREATE KEYSPACE ks WITH REPLICATION={'class':'SimpleStrategy', 'replication_factor':
3}")
+        session.execute("CREATE TABLE ks.tbl (k INT PRIMARY KEY, v INT)")
+
+        # everything should be in sync
+        result = node1.repair(options=['ks', '--preview'])
+        self.assertIn("Previewed data was in sync", result.stdout)
+        self.assert_no_repair_history(session)
+
+        # make data inconsistent between nodes
+        stmt = SimpleStatement("INSERT INTO ks.tbl (k,v) VALUES (%s, %s)")
+        stmt.consistency_level = ConsistencyLevel.ALL
+        for i in range(10):
+            session.execute(stmt, (i, i))
+        node3.flush()
+        time.sleep(1)
+        node3.stop(gently=False)
+        stmt.consistency_level = ConsistencyLevel.QUORUM
+
+        session = self.exclusive_cql_connection(node1)
+        for i in range(10):
+            session.execute(stmt, (i + 10, i + 10))
+        node1.flush()
+        time.sleep(1)
+        node1.stop(gently=False)
+        node3.start(wait_other_notice=True, wait_for_binary_proto=True)
+        session = self.exclusive_cql_connection(node2)
+        for i in range(10):
+            session.execute(stmt, (i + 20, i + 20))
+        node1.start(wait_other_notice=True, wait_for_binary_proto=True)
+
+        # data should not be in sync for full and unrepaired previews
+        result = node1.repair(options=['ks', '--preview'])
+        self.assertIn("Total estimated streaming", result.stdout)
+        self.assertNotIn("Previewed data was in sync", result.stdout)
+
+        result = node1.repair(options=['ks', '--preview', '--full'])
+        self.assertIn("Total estimated streaming", result.stdout)
+        self.assertNotIn("Previewed data was in sync", result.stdout)
+
+        # repaired data should be in sync anyway
+        result = node1.repair(options=['ks', '--validate'])
+        self.assertIn("Repaired data is in sync", result.stdout)
+
+        self.assert_no_repair_history(session)
+
+        # repair the data...
+        node1.repair(options=['ks'])
+        for node in cluster.nodelist():
+            node.nodetool('compact ks tbl')
+
+        # ...and everything should be in sync
+        result = node1.repair(options=['ks', '--preview'])
+        self.assertIn("Previewed data was in sync", result.stdout)
+
+        result = node1.repair(options=['ks', '--preview', '--full'])
+        self.assertIn("Previewed data was in sync", result.stdout)
+
+        result = node1.repair(options=['ks', '--validate'])
+        self.assertIn("Repaired data is in sync", result.stdout)


---------------------------------------------------------------------
To unsubscribe, e-mail: commits-unsubscribe@cassandra.apache.org
For additional commands, e-mail: commits-help@cassandra.apache.org


Mime
View raw message