diff --git a/cassandra/pom.xml b/cassandra/pom.xml
index 570e010f..eaf9bba6 100644
--- a/cassandra/pom.xml
+++ b/cassandra/pom.xml
@@ -1,141 +1,147 @@
 <?xml version="1.0" encoding="UTF-8"?>
 
 <!--
 Copyright (c) 2012-2016 YCSB contributors. All rights reserved.
 
 Licensed under the Apache License, Version 2.0 (the "License"); you
 may not use this file except in compliance with the License. You
 may obtain a copy of the License at
 
 http://www.apache.org/licenses/LICENSE-2.0
 
 Unless required by applicable law or agreed to in writing, software
 distributed under the License is distributed on an "AS IS" BASIS,
 WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or
 implied. See the License for the specific language governing
 permissions and limitations under the License. See accompanying
 LICENSE file.
 -->
 
 <project xmlns="http://maven.apache.org/POM/4.0.0" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
   xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/maven-v4_0_0.xsd">
   <modelVersion>4.0.0</modelVersion>
   <parent>
     <groupId>com.yahoo.ycsb</groupId>
     <artifactId>binding-parent</artifactId>
     <version>0.12.0-SNAPSHOT</version>
     <relativePath>../binding-parent</relativePath>
   </parent>
 
   <artifactId>cassandra-binding</artifactId>
   <name>Cassandra 2.1+ DB Binding</name>
   <packaging>jar</packaging>
 
   <properties>
     <!-- Skip tests by default. will be activated by jdk8 profile -->
     <skipTests>true</skipTests>
   </properties>
 
   <dependencies>
     <!-- CQL driver -->
     <dependency>
       <groupId>com.datastax.cassandra</groupId>
       <artifactId>cassandra-driver-core</artifactId>
       <version>${cassandra.cql.version}</version>
     </dependency>
     <dependency>
       <groupId>com.yahoo.ycsb</groupId>
       <artifactId>core</artifactId>
       <version>${project.version}</version>
       <scope>provided</scope>
     </dependency>
     <dependency>
       <groupId>org.cassandraunit</groupId>
       <artifactId>cassandra-unit</artifactId>
       <version>3.0.0.1</version>
       <classifier>shaded</classifier>
       <scope>test</scope>
     </dependency>
+    <dependency>
+      <groupId>org.slf4j</groupId>
+      <artifactId>slf4j-simple</artifactId>
+      <version>1.7.21</version>
+      <scope>test</scope>
+    </dependency>
     <dependency>
       <groupId>junit</groupId>
       <artifactId>junit</artifactId>
       <version>4.12</version>
       <scope>test</scope>
     </dependency>
     <!-- only for Cassandra test (Cassandra 2.2+ uses Sigar for collecting system information, and Sigar requires some native lib files) -->
 	  <dependency>
 	    <groupId>org.hyperic</groupId>
 	    <artifactId>sigar-dist</artifactId>
 	    <version>1.6.4.129</version>
 	    <type>zip</type>
 	    <scope>test</scope>
 	  </dependency>
   </dependencies>
 
   <profiles>
     <!-- Cassandra 2.2+ requires JDK8 to run, so none of our tests
          will work unless we're using jdk8.
       -->
     <profile>
       <id>jdk8-tests</id>
       <activation>
         <jdk>1.8</jdk>
       </activation>
       <properties>
         <skipTests>false</skipTests>
       </properties>
     </profile>
   </profiles>
   <!-- sigar-dist can be downloaded from jboss repository -->
 	<repositories>
 		<repository>
 			<id>central2</id>
 			<name>sigar Repository</name>
 			<url>http://repository.jboss.org/nexus/content/groups/public-jboss/</url>
 			<layout>default</layout>
 			<snapshots>
 				<enabled>false</enabled>
 			</snapshots>
 		</repository>
 	</repositories>
 	<!-- unzip sigar-dist/lib files. 
 		References: 
 		http://stackoverflow.com/questions/5388661/unzip-dependency-in-maven 
 		https://arviarya.wordpress.com/2013/09/22/sigar-access-operating-system-and-hardware-level-information/
 	 -->
  	<build>
 	 	<plugins>
 	 		<plugin>
 			    <groupId>org.apache.maven.plugins</groupId>
 			    <artifactId>maven-dependency-plugin</artifactId>
 			    <executions>
 			      <execution>
 			        <id>unpack-sigar</id>
 			        <phase>process-test-resources<!-- or any other valid maven phase --></phase>
 			        <goals>
 			          <goal>unpack-dependencies</goal>
 			        </goals>
 			        <configuration>
 			          <includeGroupIds>org.hyperic</includeGroupIds>
 			          <includeArtifactIds>sigar-dist</includeArtifactIds>
 			          <includes>**/sigar-bin/lib/*</includes>
 					  <excludes>**/sigar-bin/lib/*jar</excludes>
 			          <outputDirectory>
 			             ${project.build.directory}/cassandra-dependency
 			          </outputDirectory>
 			        </configuration>
 			      </execution>
 			    </executions>
 			</plugin>
 			<plugin>
 			  <groupId>org.apache.maven.plugins</groupId>
 			  <artifactId>maven-surefire-plugin</artifactId>
 			  <version>2.8</version>
 			  <configuration>
 			    <argLine>-Djava.library.path=${project.build.directory}/cassandra-dependency/hyperic-sigar-1.6.4/sigar-bin/lib</argLine>
 			  </configuration>
 			</plugin>
 			
 	 	</plugins>
  	</build>
 </project>
diff --git a/cassandra/src/test/java/com/yahoo/ycsb/db/CassandraCQLClientTest.java b/cassandra/src/test/java/com/yahoo/ycsb/db/CassandraCQLClientTest.java
index 60b7e2f3..870d5a7d 100644
--- a/cassandra/src/test/java/com/yahoo/ycsb/db/CassandraCQLClientTest.java
+++ b/cassandra/src/test/java/com/yahoo/ycsb/db/CassandraCQLClientTest.java
@@ -1,177 +1,181 @@
 /**
  * Copyright (c) 2015 YCSB contributors All rights reserved.
  *
  * Licensed under the Apache License, Version 2.0 (the "License"); you
  * may not use this file except in compliance with the License. You
  * may obtain a copy of the License at
  *
  * http://www.apache.org/licenses/LICENSE-2.0
  *
  * Unless required by applicable law or agreed to in writing, software
  * distributed under the License is distributed on an "AS IS" BASIS,
  * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or
  * implied. See the License for the specific language governing
  * permissions and limitations under the License. See accompanying
  * LICENSE file.
  */
 
 package com.yahoo.ycsb.db;
 
 import static org.hamcrest.MatcherAssert.assertThat;
 import static org.hamcrest.Matchers.hasEntry;
 import static org.hamcrest.Matchers.hasSize;
 import static org.hamcrest.Matchers.is;
 import static org.hamcrest.Matchers.notNullValue;
 
 import com.google.common.collect.Sets;
 
 import com.datastax.driver.core.ResultSet;
 import com.datastax.driver.core.Row;
 import com.datastax.driver.core.Session;
 import com.datastax.driver.core.Statement;
 import com.datastax.driver.core.querybuilder.Insert;
 import com.datastax.driver.core.querybuilder.QueryBuilder;
 import com.datastax.driver.core.querybuilder.Select;
 import com.yahoo.ycsb.ByteIterator;
 import com.yahoo.ycsb.Status;
 import com.yahoo.ycsb.StringByteIterator;
 import com.yahoo.ycsb.measurements.Measurements;
 import com.yahoo.ycsb.workloads.CoreWorkload;
 
 import org.cassandraunit.CassandraCQLUnit;
 import org.cassandraunit.dataset.cql.ClassPathCQLDataSet;
 import org.junit.After;
 import org.junit.Before;
 import org.junit.ClassRule;
 import org.junit.Test;
 
 import java.util.HashMap;
 import java.util.Map;
 import java.util.Properties;
 import java.util.Set;
 
 /**
  * Integration tests for the Cassandra client
  */
 public class CassandraCQLClientTest {
+  // Change the default Cassandra timeout from 10s to 120s for slow CI machines
+  private final static long timeout = 120000L;
+
   private final static String TABLE = "usertable";
   private final static String HOST = "localhost";
   private final static int PORT = 9142;
   private final static String DEFAULT_ROW_KEY = "user1";
 
   private CassandraCQLClient client;
   private Session session;
 
   @ClassRule
-  public static CassandraCQLUnit cassandraUnit = new CassandraCQLUnit(new ClassPathCQLDataSet("ycsb.cql", "ycsb"));
+  public static CassandraCQLUnit cassandraUnit = new CassandraCQLUnit(
+    new ClassPathCQLDataSet("ycsb.cql", "ycsb"), null, timeout);
 
   @Before
   public void setUp() throws Exception {
     session = cassandraUnit.getSession();
 
     Properties p = new Properties();
     p.setProperty("hosts", HOST);
     p.setProperty("port", Integer.toString(PORT));
     p.setProperty("table", TABLE);
 
     Measurements.setProperties(p);
     final CoreWorkload workload = new CoreWorkload();
     workload.init(p);
     client = new CassandraCQLClient();
     client.setProperties(p);
     client.init();
   }
 
   @After
   public void tearDownClient() throws Exception {
     if (client != null) {
       client.cleanup();
     }
     client = null;
   }
 
   @After
   public void clearTable() throws Exception {
     // Clear the table so that each test starts fresh.
     final Statement truncate = QueryBuilder.truncate(TABLE);
     if (cassandraUnit != null) {
       cassandraUnit.getSession().execute(truncate);
     }
   }
 
   @Test
   public void testReadMissingRow() throws Exception {
     final HashMap<String, ByteIterator> result = new HashMap<String, ByteIterator>();
     final Status status = client.read(TABLE, "Missing row", null, result);
     assertThat(result.size(), is(0));
     assertThat(status, is(Status.NOT_FOUND));
   }
 
   private void insertRow() {
     final String rowKey = DEFAULT_ROW_KEY;
     Insert insertStmt = QueryBuilder.insertInto(TABLE);
     insertStmt.value(CassandraCQLClient.YCSB_KEY, rowKey);
 
     insertStmt.value("field0", "value1");
     insertStmt.value("field1", "value2");
     session.execute(insertStmt);
   }
 
   @Test
   public void testRead() throws Exception {
     insertRow();
 
     final HashMap<String, ByteIterator> result = new HashMap<String, ByteIterator>();
     final Status status = client.read(CoreWorkload.table, DEFAULT_ROW_KEY, null, result);
     assertThat(status, is(Status.OK));
     assertThat(result.entrySet(), hasSize(11));
     assertThat(result, hasEntry("field2", null));
 
     final HashMap<String, String> strResult = new HashMap<String, String>();
     for (final Map.Entry<String, ByteIterator> e : result.entrySet()) {
       if (e.getValue() != null) {
         strResult.put(e.getKey(), e.getValue().toString());
       }
     }
     assertThat(strResult, hasEntry(CassandraCQLClient.YCSB_KEY, DEFAULT_ROW_KEY));
     assertThat(strResult, hasEntry("field0", "value1"));
     assertThat(strResult, hasEntry("field1", "value2"));
   }
 
   @Test
   public void testReadSingleColumn() throws Exception {
     insertRow();
     final HashMap<String, ByteIterator> result = new HashMap<String, ByteIterator>();
     final Set<String> fields = Sets.newHashSet("field1");
     final Status status = client.read(CoreWorkload.table, DEFAULT_ROW_KEY, fields, result);
     assertThat(status, is(Status.OK));
     assertThat(result.entrySet(), hasSize(1));
     final Map<String, String> strResult = StringByteIterator.getStringMap(result);
     assertThat(strResult, hasEntry("field1", "value2"));
   }
 
   @Test
   public void testUpdate() throws Exception {
     final String key = "key";
     final HashMap<String, String> input = new HashMap<String, String>();
     input.put("field0", "value1");
     input.put("field1", "value2");
 
     final Status status = client.insert(TABLE, key, StringByteIterator.getByteIteratorMap(input));
     assertThat(status, is(Status.OK));
 
     // Verify result
     final Select selectStmt =
         QueryBuilder.select("field0", "field1")
             .from(TABLE)
             .where(QueryBuilder.eq(CassandraCQLClient.YCSB_KEY, key))
             .limit(1);
 
     final ResultSet rs = session.execute(selectStmt);
     final Row row = rs.one();
     assertThat(row, notNullValue());
     assertThat(rs.isExhausted(), is(true));
     assertThat(row.getString("field0"), is("value1"));
     assertThat(row.getString("field1"), is("value2"));
   }
 }