cassandra-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From s...@apache.org
Subject cassandra git commit: Fix ClientWarningsTest following CASSANDRA-10876
Date Wed, 16 Mar 2016 11:35:03 GMT
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 <joel.knighton@datastax.com>
Authored: Tue Mar 15 18:51:23 2016 -0500
Committer: Sam Tunnicliffe <sam@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());
         }
     }
 


Mime
View raw message