diff --git a/ndbench-cass-plugins/src/main/java/com/netflix/ndbench/plugin/cass/CassJavaDriverGeneric.java b/ndbench-cass-plugins/src/main/java/com/netflix/ndbench/plugin/cass/CassJavaDriverGeneric.java
index 1fcde072..456fac8c 100644
--- a/ndbench-cass-plugins/src/main/java/com/netflix/ndbench/plugin/cass/CassJavaDriverGeneric.java
+++ b/ndbench-cass-plugins/src/main/java/com/netflix/ndbench/plugin/cass/CassJavaDriverGeneric.java
@@ -52,15 +52,15 @@ public String readSingle(String key) throws Exception {
 
     @Override
     public String writeSingle(String key) throws Exception {
-        BatchStatement batch = new BatchStatement();
+        BatchStatement batch = new BatchStatement(BatchStatement.Type.UNLOGGED);
         for (int i = 0; i < this.MaxColCount; i++) {
             BoundStatement bStmt = writePstmt.bind();
             bStmt.setString("key", key);
             bStmt.setInt("column1", i);
             bStmt.setString("value", this.dataGenerator.getRandomValue());
-            bStmt.setConsistencyLevel(this.WriteConsistencyLevel);
             batch.add(bStmt);
         }
+	batch.setConsistencyLevel(this.WriteConsistencyLevel);
         session.execute(batch);
         batch.clear();
         return ResultOK;