diff --git a/astyanax-cql/src/main/java/com/netflix/astyanax/cql/CqlKeyspaceImpl.java b/astyanax-cql/src/main/java/com/netflix/astyanax/cql/CqlKeyspaceImpl.java
index c9d40f983..b6c0d9f0e 100644
--- a/astyanax-cql/src/main/java/com/netflix/astyanax/cql/CqlKeyspaceImpl.java
+++ b/astyanax-cql/src/main/java/com/netflix/astyanax/cql/CqlKeyspaceImpl.java
@@ -401,7 +401,7 @@ public String apply(Host input) {
 				this.cluster.getMetrics().getRegistry().addListener((MetricRegistryListener) this.metricsRegListener);
 			
 			Logger.info("Connecting to cluster");
-			session = cluster.connect();
+			session = cluster.newSession();
 			Logger.info("Done connecting to cluster, session object created");
 
 		} catch (RuntimeException e) {