diff --git a/src/test/java/org/springframework/cassandra/test/integration/core/cql/generator/AbstractEmbeddedCassandraIntegrationTest.java b/src/test/java/org/springframework/cassandra/test/integration/core/cql/generator/AbstractEmbeddedCassandraIntegrationTest.java
index be34c18f3..f6046ac02 100644
--- a/src/test/java/org/springframework/cassandra/test/integration/core/cql/generator/AbstractEmbeddedCassandraIntegrationTest.java
+++ b/src/test/java/org/springframework/cassandra/test/integration/core/cql/generator/AbstractEmbeddedCassandraIntegrationTest.java
@@ -6,7 +6,6 @@ import java.util.UUID;
 import org.apache.cassandra.exceptions.ConfigurationException;
 import org.apache.thrift.transport.TTransportException;
 import org.cassandraunit.utils.EmbeddedCassandraServerHelper;
-import org.junit.After;
 import org.junit.Before;
 import org.junit.BeforeClass;
 
@@ -22,10 +21,6 @@ public abstract class AbstractEmbeddedCassandraIntegrationTest {
 		EmbeddedCassandraServerHelper.startEmbeddedCassandra("cassandra.yaml");
 	}
 
-	/**
-	 * Whether to clear the cluster before the next test.
-	 */
-	protected boolean clear = true;
 	/**
 	 * Whether to connect to Cassandra.
 	 */
@@ -73,11 +68,4 @@ public abstract class AbstractEmbeddedCassandraIntegrationTest {
 			}
 		}
 	}
-
-	@After
-	public void after() {
-		if (clear && connected()) {
-			EmbeddedCassandraServerHelper.cleanEmbeddedCassandra();
-		}
-	}
 }