http://git-wip-us.apache.org/repos/asf/cassandra/blob/06c130e3/tools/stress/src/org/apache/cassandra/stress/util/JavaDriverClient.java
----------------------------------------------------------------------
diff --git 
a/tools/stress/src/org/apache/cassandra/stress/util/JavaDriverClient.java 
b/tools/stress/src/org/apache/cassandra/stress/util/JavaDriverClient.java
index d82ebfd..8be1c96 100644
--- a/tools/stress/src/org/apache/cassandra/stress/util/JavaDriverClient.java
+++ b/tools/stress/src/org/apache/cassandra/stress/util/JavaDriverClient.java
@@ -142,7 +142,7 @@ public class JavaDriverClient
 
     public ResultSet execute(String query, 
org.apache.cassandra.db.ConsistencyLevel consistency)
     {
-        SimpleStatement stmt = new SimpleStatement(query);
+        SimpleStatement stmt = getSession().newSimpleStatement(query);
         stmt.setConsistencyLevel(from(consistency));
         return getSession().execute(stmt);
     }

Reply via email to