You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@cassandra.apache.org by sa...@apache.org on 2016/03/16 12:35:03 UTC
cassandra git commit: Fix ClientWarningsTest following CASSANDRA-10876
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 <jo...@datastax.com>
Authored: Tue Mar 15 18:51:23 2016 -0500
Committer: Sam Tunnicliffe <sa...@beobal.com>
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());
}
}