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);
}