From e72b13577d9d836aa7f0bc494725b1607aa8eb83 Mon Sep 17 00:00:00 2001 From: Stephen Sisk Date: Tue, 11 Apr 2017 14:36:05 -0700 Subject: [PATCH] HIFIO Cassandra tests were failing if run twice in a row without a clean --- .../io/hadoop/inputformat/HIFIOWithEmbeddedCassandraTest.java | 1 + 1 file changed, 1 insertion(+) diff --git a/sdks/java/io/hadoop/jdk1.8-tests/src/test/java/org/apache/beam/sdk/io/hadoop/inputformat/HIFIOWithEmbeddedCassandraTest.java b/sdks/java/io/hadoop/jdk1.8-tests/src/test/java/org/apache/beam/sdk/io/hadoop/inputformat/HIFIOWithEmbeddedCassandraTest.java index 402c19ce2424..50b2c4f09947 100644 --- a/sdks/java/io/hadoop/jdk1.8-tests/src/test/java/org/apache/beam/sdk/io/hadoop/inputformat/HIFIOWithEmbeddedCassandraTest.java +++ b/sdks/java/io/hadoop/jdk1.8-tests/src/test/java/org/apache/beam/sdk/io/hadoop/inputformat/HIFIOWithEmbeddedCassandraTest.java @@ -147,6 +147,7 @@ public Configuration getConfiguration() { } public static void createCassandraData() throws Exception { + session.execute("DROP KEYSPACE IF EXISTS " + CASSANDRA_KEYSPACE); session.execute("CREATE KEYSPACE " + CASSANDRA_KEYSPACE + " WITH REPLICATION = {'class':'SimpleStrategy', 'replication_factor':1};"); session.execute("USE " + CASSANDRA_KEYSPACE);