Repository: cassandra-dtest Updated Branches: refs/heads/master 0c46c4015 -> 194ad8a22
compact storage when testing thrift Patch by marcuse; reviewed by Jason Brown for CASSANDRA-14583 Project: http://git-wip-us.apache.org/repos/asf/cassandra-dtest/repo Commit: http://git-wip-us.apache.org/repos/asf/cassandra-dtest/commit/194ad8a2 Tree: http://git-wip-us.apache.org/repos/asf/cassandra-dtest/tree/194ad8a2 Diff: http://git-wip-us.apache.org/repos/asf/cassandra-dtest/diff/194ad8a2 Branch: refs/heads/master Commit: 194ad8a22315f0410155ab5eb2283d006a4fdd37 Parents: 0c46c40 Author: Marcus Eriksson <marc...@apache.org> Authored: Mon Jul 23 10:03:17 2018 +0200 Committer: Marcus Eriksson <marc...@apache.org> Committed: Wed Jul 25 07:52:00 2018 +0200 ---------------------------------------------------------------------- write_failures_test.py | 6 +++--- 1 file changed, 3 insertions(+), 3 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/cassandra-dtest/blob/194ad8a2/write_failures_test.py ---------------------------------------------------------------------- diff --git a/write_failures_test.py b/write_failures_test.py index ece6245..bb2deb8 100644 --- a/write_failures_test.py +++ b/write_failures_test.py @@ -42,7 +42,7 @@ class TestWriteFailures(Tester): self.consistency_level = ConsistencyLevel.ALL self.failing_nodes = [1, 2] - def _prepare_cluster(self, start_rpc=False): + def _prepare_cluster(self, start_rpc=False, compact_storage=False): self.cluster.populate(3) if start_rpc: @@ -59,7 +59,7 @@ class TestWriteFailures(Tester): """ % (KEYSPACE, self.replication_factor)) session.set_keyspace(KEYSPACE) - session.execute("CREATE TABLE IF NOT EXISTS mytable (key text PRIMARY KEY, value text)") + session.execute("CREATE TABLE IF NOT EXISTS mytable (key text PRIMARY KEY, value text) %s"%("WITH COMPACT STORAGE" if compact_storage else '')) session.execute("CREATE TABLE IF NOT EXISTS countertable (key uuid PRIMARY KEY, value counter)") for idx in self.failing_nodes: @@ -214,7 +214,7 @@ class TestWriteFailures(Tester): """ A thrift client receives a TimedOutException """ - self._prepare_cluster(start_rpc=True) + self._prepare_cluster(start_rpc=True, compact_storage=True) self.expected_expt = thrift_types.TimedOutException client = get_thrift_client() --------------------------------------------------------------------- To unsubscribe, e-mail: commits-unsubscr...@cassandra.apache.org For additional commands, e-mail: commits-h...@cassandra.apache.org
