Clean HFIOWithEmbeddedCassandraTest before Execution HIFIO Cassandra tests were failing if run twice in a row without a clean
Project: http://git-wip-us.apache.org/repos/asf/beam/repo Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/041b636b Tree: http://git-wip-us.apache.org/repos/asf/beam/tree/041b636b Diff: http://git-wip-us.apache.org/repos/asf/beam/diff/041b636b Branch: refs/heads/DSL_SQL Commit: 041b636b0d912242ae1292c6fb2e5d0fa12fdaab Parents: a2d328a Author: Stephen Sisk <[email protected]> Authored: Tue Apr 11 14:36:05 2017 -0700 Committer: Thomas Groh <[email protected]> Committed: Tue Apr 11 16:17:23 2017 -0700 ---------------------------------------------------------------------- .../sdk/io/hadoop/inputformat/HIFIOWithEmbeddedCassandraTest.java | 1 + 1 file changed, 1 insertion(+) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/beam/blob/041b636b/sdks/java/io/hadoop/jdk1.8-tests/src/test/java/org/apache/beam/sdk/io/hadoop/inputformat/HIFIOWithEmbeddedCassandraTest.java ---------------------------------------------------------------------- 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 402c19c..50b2c4f 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 class HIFIOWithEmbeddedCassandraTest implements Serializable { } 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);
