Repository: cassandra Updated Branches: refs/heads/trunk 39d5e6aae -> 9e9161b79
Fix ClientWarningsTest following CASSANDRA-10876 Patch by Joel Knighton; reviewed by Sam Tunnicliffe for CASSANDRA-11357 Project: http://git-wip-us.apache.org/repos/asf/cassandra/repo Commit: http://git-wip-us.apache.org/repos/asf/cassandra/commit/9e9161b7 Tree: http://git-wip-us.apache.org/repos/asf/cassandra/tree/9e9161b7 Diff: http://git-wip-us.apache.org/repos/asf/cassandra/diff/9e9161b7 Branch: refs/heads/trunk Commit: 9e9161b79c033ea4d4c63e6a1ecec1660eb567b5 Parents: 39d5e6a Author: Joel Knighton <[email protected]> Authored: Tue Mar 15 18:51:23 2016 -0500 Committer: Sam Tunnicliffe <[email protected]> Committed: Wed Mar 16 11:30:20 2016 +0000 ---------------------------------------------------------------------- test/unit/org/apache/cassandra/service/ClientWarningsTest.java | 6 +++++- 1 file changed, 5 insertions(+), 1 deletion(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/cassandra/blob/9e9161b7/test/unit/org/apache/cassandra/service/ClientWarningsTest.java ---------------------------------------------------------------------- diff --git a/test/unit/org/apache/cassandra/service/ClientWarningsTest.java b/test/unit/org/apache/cassandra/service/ClientWarningsTest.java index cf14d55..78b1c88 100644 --- a/test/unit/org/apache/cassandra/service/ClientWarningsTest.java +++ b/test/unit/org/apache/cassandra/service/ClientWarningsTest.java @@ -72,9 +72,13 @@ public class ClientWarningsTest extends CQLTester { client.connect(false); - QueryMessage query = new QueryMessage(createBatchStatement(DatabaseDescriptor.getBatchSizeWarnThreshold()), QueryOptions.DEFAULT); + QueryMessage query = new QueryMessage(createBatchStatement2(DatabaseDescriptor.getBatchSizeWarnThreshold() / 2 + 1), QueryOptions.DEFAULT); Message.Response resp = client.execute(query); assertEquals(1, resp.getWarnings().size()); + + query = new QueryMessage(createBatchStatement(DatabaseDescriptor.getBatchSizeWarnThreshold()), QueryOptions.DEFAULT); + resp = client.execute(query); + assertNull(resp.getWarnings()); } }
