This is an automated email from the ASF dual-hosted git repository.
sblackmon pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/streams-examples.git
The following commit(s) were added to refs/heads/master by this push:
new 6326de5 adapt to STREAMS-529
6326de5 is described below
commit 6326de5a1d3bbeb7430461ef1a86490ce42a614c
Author: Steve Blackmon @steveblackmon <[email protected]>
AuthorDate: Sat Oct 28 14:14:42 2017 -0500
adapt to STREAMS-529
---
.../src/main/scala/org/apache/streams/examples/flink/FlinkBase.scala | 4 ++--
.../src/main/java/org/apache/streams/example/ElasticsearchHdfs.java | 2 +-
.../src/main/java/org/apache/streams/example/HdfsElasticsearch.java | 2 +-
.../main/java/org/apache/streams/example/ElasticsearchReindex.java | 2 +-
.../main/java/org/apache/streams/example/MongoElasticsearchSync.java | 2 +-
.../src/main/java/org/apache/streams/example/TwitterFollowNeo4j.java | 2 +-
.../java/org/apache/streams/example/TwitterHistoryElasticsearch.java | 2 +-
.../org/apache/streams/example/TwitterUserstreamElasticsearch.java | 2 +-
8 files changed, 9 insertions(+), 9 deletions(-)
diff --git
a/flink/flink-twitter-collection/src/main/scala/org/apache/streams/examples/flink/FlinkBase.scala
b/flink/flink-twitter-collection/src/main/scala/org/apache/streams/examples/flink/FlinkBase.scala
index f4ce6dd..96e2de5 100644
---
a/flink/flink-twitter-collection/src/main/scala/org/apache/streams/examples/flink/FlinkBase.scala
+++
b/flink/flink-twitter-collection/src/main/scala/org/apache/streams/examples/flink/FlinkBase.scala
@@ -62,11 +62,11 @@ trait FlinkBase {
}
def setup(configUrl : String): Boolean = {
- BASELOGGER.info("StreamsConfigurator.config: {}",
StreamsConfigurator.config)
+ BASELOGGER.info("StreamsConfigurator.config: {}",
StreamsConfigurator.getConfig)
if(StringUtils.isNotEmpty(configUrl)) {
BASELOGGER.info("StreamsConfigurator.resolveConfig(configUrl): {}",
StreamsConfigurator.resolveConfig(configUrl))
try {
- typesafe =
StreamsConfigurator.resolveConfig(configUrl).withFallback(StreamsConfigurator.config).resolve()
+ typesafe =
StreamsConfigurator.resolveConfig(configUrl).withFallback(StreamsConfigurator.getConfig).resolve()
} catch {
case mue: MalformedURLException => {
BASELOGGER.error("Invalid Configuration URL: ", mue)
diff --git
a/local/elasticsearch-hdfs/src/main/java/org/apache/streams/example/ElasticsearchHdfs.java
b/local/elasticsearch-hdfs/src/main/java/org/apache/streams/example/ElasticsearchHdfs.java
index b4485b1..d2d0869 100644
---
a/local/elasticsearch-hdfs/src/main/java/org/apache/streams/example/ElasticsearchHdfs.java
+++
b/local/elasticsearch-hdfs/src/main/java/org/apache/streams/example/ElasticsearchHdfs.java
@@ -51,7 +51,7 @@ public class ElasticsearchHdfs implements Runnable {
public static void main(String[] args)
{
- LOGGER.info(StreamsConfigurator.config.toString());
+ LOGGER.info(StreamsConfigurator.getConfig().toString());
ElasticsearchHdfs backup = new ElasticsearchHdfs();
new Thread(backup).start();
}
diff --git
a/local/elasticsearch-hdfs/src/main/java/org/apache/streams/example/HdfsElasticsearch.java
b/local/elasticsearch-hdfs/src/main/java/org/apache/streams/example/HdfsElasticsearch.java
index 4fac11d..cca8472 100644
---
a/local/elasticsearch-hdfs/src/main/java/org/apache/streams/example/HdfsElasticsearch.java
+++
b/local/elasticsearch-hdfs/src/main/java/org/apache/streams/example/HdfsElasticsearch.java
@@ -51,7 +51,7 @@ public class HdfsElasticsearch implements Runnable {
public static void main(String[] args)
{
- LOGGER.info(StreamsConfigurator.config.toString());
+ LOGGER.info(StreamsConfigurator.getConfig().toString());
HdfsElasticsearch restore = new HdfsElasticsearch();
new Thread(restore).start();
}
diff --git
a/local/elasticsearch-reindex/src/main/java/org/apache/streams/example/ElasticsearchReindex.java
b/local/elasticsearch-reindex/src/main/java/org/apache/streams/example/ElasticsearchReindex.java
index 8b92c03..a1ac353 100644
---
a/local/elasticsearch-reindex/src/main/java/org/apache/streams/example/ElasticsearchReindex.java
+++
b/local/elasticsearch-reindex/src/main/java/org/apache/streams/example/ElasticsearchReindex.java
@@ -52,7 +52,7 @@ public class ElasticsearchReindex implements Runnable {
public static void main(String[] args)
{
- LOGGER.info(StreamsConfigurator.config.toString());
+ LOGGER.info(StreamsConfigurator.getConfig().toString());
ElasticsearchReindex reindex = new ElasticsearchReindex();
diff --git
a/local/mongo-elasticsearch-sync/src/main/java/org/apache/streams/example/MongoElasticsearchSync.java
b/local/mongo-elasticsearch-sync/src/main/java/org/apache/streams/example/MongoElasticsearchSync.java
index 2d994b9..58001d6 100644
---
a/local/mongo-elasticsearch-sync/src/main/java/org/apache/streams/example/MongoElasticsearchSync.java
+++
b/local/mongo-elasticsearch-sync/src/main/java/org/apache/streams/example/MongoElasticsearchSync.java
@@ -51,7 +51,7 @@ public class MongoElasticsearchSync implements Runnable {
public static void main(String[] args)
{
- LOGGER.info(StreamsConfigurator.config.toString());
+ LOGGER.info(StreamsConfigurator.getConfig().toString());
MongoElasticsearchSync sync = new MongoElasticsearchSync();
diff --git
a/local/twitter-follow-neo4j/src/main/java/org/apache/streams/example/TwitterFollowNeo4j.java
b/local/twitter-follow-neo4j/src/main/java/org/apache/streams/example/TwitterFollowNeo4j.java
index 5098061..7a3ff46 100644
---
a/local/twitter-follow-neo4j/src/main/java/org/apache/streams/example/TwitterFollowNeo4j.java
+++
b/local/twitter-follow-neo4j/src/main/java/org/apache/streams/example/TwitterFollowNeo4j.java
@@ -93,7 +93,7 @@ public class TwitterFollowNeo4j implements Runnable {
public static void main(String[] args) {
- LOGGER.info(StreamsConfigurator.config.toString());
+ LOGGER.info(StreamsConfigurator.getConfig().toString());
TwitterFollowNeo4j stream = new TwitterFollowNeo4j();
diff --git
a/local/twitter-history-elasticsearch/src/main/java/org/apache/streams/example/TwitterHistoryElasticsearch.java
b/local/twitter-history-elasticsearch/src/main/java/org/apache/streams/example/TwitterHistoryElasticsearch.java
index 60f3405..d4fd976 100644
---
a/local/twitter-history-elasticsearch/src/main/java/org/apache/streams/example/TwitterHistoryElasticsearch.java
+++
b/local/twitter-history-elasticsearch/src/main/java/org/apache/streams/example/TwitterHistoryElasticsearch.java
@@ -57,7 +57,7 @@ public class TwitterHistoryElasticsearch implements Runnable {
public static void main(String[] args)
{
- LOGGER.info(StreamsConfigurator.config.toString());
+ LOGGER.info(StreamsConfigurator.getConfig().toString());
TwitterHistoryElasticsearch history = new TwitterHistoryElasticsearch();
diff --git
a/local/twitter-userstream-elasticsearch/src/main/java/org/apache/streams/example/TwitterUserstreamElasticsearch.java
b/local/twitter-userstream-elasticsearch/src/main/java/org/apache/streams/example/TwitterUserstreamElasticsearch.java
index 61cd582..fdfb39b 100644
---
a/local/twitter-userstream-elasticsearch/src/main/java/org/apache/streams/example/TwitterUserstreamElasticsearch.java
+++
b/local/twitter-userstream-elasticsearch/src/main/java/org/apache/streams/example/TwitterUserstreamElasticsearch.java
@@ -76,7 +76,7 @@ public class TwitterUserstreamElasticsearch implements
Runnable {
public static void main(String[] args)
{
- LOGGER.info(StreamsConfigurator.config.toString());
+ LOGGER.info(StreamsConfigurator.getConfig().toString());
TwitterUserstreamElasticsearch userstream = new
TwitterUserstreamElasticsearch();
new Thread(userstream).start();
--
To stop receiving notification emails like this one, please contact
['"[email protected]" <[email protected]>'].
