You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@beam.apache.org by tg...@apache.org on 2017/04/11 23:18:03 UTC
[1/2] beam git commit: Clean HFIOWithEmbeddedCassandraTest before
Execution
Repository: beam
Updated Branches:
refs/heads/master a2d328a2d -> ccf247c1d
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/master
Commit: 041b636b0d912242ae1292c6fb2e5d0fa12fdaab
Parents: a2d328a
Author: Stephen Sisk <si...@google.com>
Authored: Tue Apr 11 14:36:05 2017 -0700
Committer: Thomas Groh <tg...@google.com>
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);
[2/2] beam git commit: This closes #2499
Posted by tg...@apache.org.
This closes #2499
Project: http://git-wip-us.apache.org/repos/asf/beam/repo
Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/ccf247c1
Tree: http://git-wip-us.apache.org/repos/asf/beam/tree/ccf247c1
Diff: http://git-wip-us.apache.org/repos/asf/beam/diff/ccf247c1
Branch: refs/heads/master
Commit: ccf247c1daa868cdaf441f918775c94ae6e3aa0b
Parents: a2d328a 041b636
Author: Thomas Groh <tg...@google.com>
Authored: Tue Apr 11 16:17:39 2017 -0700
Committer: Thomas Groh <tg...@google.com>
Committed: Tue Apr 11 16:17:39 2017 -0700
----------------------------------------------------------------------
.../sdk/io/hadoop/inputformat/HIFIOWithEmbeddedCassandraTest.java | 1 +
1 file changed, 1 insertion(+)
----------------------------------------------------------------------