diff --git a/src/main/java/org/commonjava/indy/service/tracking/data/cassandra/CassandraTrackingQuery.java b/src/main/java/org/commonjava/indy/service/tracking/data/cassandra/CassandraTrackingQuery.java
index 72657bb..96754d3 100644
--- a/src/main/java/org/commonjava/indy/service/tracking/data/cassandra/CassandraTrackingQuery.java
+++ b/src/main/java/org/commonjava/indy/service/tracking/data/cassandra/CassandraTrackingQuery.java
@@ -137,7 +137,7 @@ private ResultSet executeSession ( BoundStatement bind )
         ResultSet trackingRecord = null;
         try
         {
-            if ( session == null )
+            if ( session == null || session.isClosed() )
             {
                 client.close();
                 client.init();