commit | 29f2ea5fb8371bbbdc03f9119459601a797194f4 | [log] [tgz] |
---|---|---|
author | Steve Blackmon @steveblackmon <sblackmon@apache.org> | Wed Oct 19 13:36:17 2016 -0500 |
committer | Steve Blackmon @steveblackmon <sblackmon@apache.org> | Wed Oct 19 13:36:17 2016 -0500 |
tree | 9e43e7759133f085d7f10a2525169a1c26886a66 | |
parent | 717e250c6786f7f17a0f40d10301d27587d51fbb [diff] |
fix last 2 tests
diff --git a/local/twitter-follow-neo4j/src/test/java/org/apache/streams/example/test/TwitterFollowNeo4jIT.java b/local/twitter-follow-neo4j/src/test/java/org/apache/streams/example/test/TwitterFollowNeo4jIT.java index 2813b08..0eed291 100644 --- a/local/twitter-follow-neo4j/src/test/java/org/apache/streams/example/test/TwitterFollowNeo4jIT.java +++ b/local/twitter-follow-neo4j/src/test/java/org/apache/streams/example/test/TwitterFollowNeo4jIT.java
@@ -57,12 +57,7 @@ File conf_file = new File("target/test-classes/TwitterFollowGraphIT.conf"); assert(conf_file.exists()); Config testResourceConfig = ConfigFactory.parseFileAnySyntax(conf_file, ConfigParseOptions.defaults().setAllowMissing(false)); - Properties graph_properties = new Properties(); - InputStream graph_stream = new FileInputStream("neo4j.properties"); - graph_properties.load(graph_stream); - Config graphProps = ConfigFactory.parseProperties(graph_properties); - Config typesafe = testResourceConfig.withFallback(graphProps).withFallback(reference).resolve(); - StreamsConfiguration streams = StreamsConfigurator.detectConfiguration(typesafe); + Config typesafe = testResourceConfig.withFallback(reference).resolve(); testConfiguration = new ComponentConfigurator<>(TwitterFollowNeo4jConfiguration.class).detectConfiguration(typesafe); }
diff --git a/local/twitter-history-elasticsearch/src/test/resources/TwitterHistoryElasticsearchIT.conf b/local/twitter-history-elasticsearch/src/test/resources/TwitterHistoryElasticsearchIT.conf index 9035ca3..1a05e32 100644 --- a/local/twitter-history-elasticsearch/src/test/resources/TwitterHistoryElasticsearchIT.conf +++ b/local/twitter-history-elasticsearch/src/test/resources/TwitterHistoryElasticsearchIT.conf
@@ -23,7 +23,7 @@ hosts += ${es.tcp.host} port = ${es.tcp.port} clusterName = elasticsearch - index = twitter_userstream_elasticsearch_it + index = twitter_history_elasticsearch_it type = activity forceUseConfig = true } \ No newline at end of file
diff --git a/local/twitter-userstream-elasticsearch/src/test/java/org/apache/streams/example/test/TwitterUserstreamElasticsearchIT.java b/local/twitter-userstream-elasticsearch/src/test/java/org/apache/streams/example/test/TwitterUserstreamElasticsearchIT.java index e2b5509..e4103e4 100644 --- a/local/twitter-userstream-elasticsearch/src/test/java/org/apache/streams/example/test/TwitterUserstreamElasticsearchIT.java +++ b/local/twitter-userstream-elasticsearch/src/test/java/org/apache/streams/example/test/TwitterUserstreamElasticsearchIT.java
@@ -78,7 +78,7 @@ } @Test - public void testReindex() throws Exception { + public void testUserstreamElasticsearch() throws Exception { TwitterUserstreamElasticsearch stream = new TwitterUserstreamElasticsearch(testConfiguration);