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.git
commit 76ed6652c13cb79fcbd98627154df6b44c708f6f Author: Steve Blackmon <[email protected]> AuthorDate: Tue Aug 4 19:44:18 2020 -0500 name file sink --- .../flink/twitter/collection/FlinkTwitterFollowingPipeline.scala | 2 +- .../examples/flink/twitter/collection/FlinkTwitterPostsPipeline.scala | 2 +- .../flink/twitter/collection/FlinkTwitterSpritzerPipeline.scala | 2 +- .../flink/twitter/collection/FlinkTwitterUserInformationPipeline.scala | 2 +- 4 files changed, 4 insertions(+), 4 deletions(-) diff --git a/streams-examples/streams-examples-flink/flink-twitter-collection/src/main/scala/org/apache/streams/examples/flink/twitter/collection/FlinkTwitterFollowingPipeline.scala b/streams-examples/streams-examples-flink/flink-twitter-collection/src/main/scala/org/apache/streams/examples/flink/twitter/collection/FlinkTwitterFollowingPipeline.scala index bae988c..6f20216 100644 --- a/streams-examples/streams-examples-flink/flink-twitter-collection/src/main/scala/org/apache/streams/examples/flink/twitter/collection/FlinkTwitterFollowingPipeline.scala +++ b/streams-examples/streams-examples-flink/flink-twitter-collection/src/main/scala/org/apache/streams/examples/flink/twitter/collection/FlinkTwitterFollowingPipeline.scala @@ -164,7 +164,7 @@ class FlinkTwitterFollowingPipeline(config: TwitterFollowingPipelineConfiguratio if( config.getTest == true ) { keyed_jsons.writeAsText(outPath,FileSystem.WriteMode.OVERWRITE) } else { - keyed_jsons.name("fileSink").addSink(fileSink) + keyed_jsons.addSink(fileSink).name("fileSink") } val result: JobExecutionResult = env.execute("FlinkTwitterFollowingPipeline") diff --git a/streams-examples/streams-examples-flink/flink-twitter-collection/src/main/scala/org/apache/streams/examples/flink/twitter/collection/FlinkTwitterPostsPipeline.scala b/streams-examples/streams-examples-flink/flink-twitter-collection/src/main/scala/org/apache/streams/examples/flink/twitter/collection/FlinkTwitterPostsPipeline.scala index 14eebc5..ed45a9f 100644 --- a/streams-examples/streams-examples-flink/flink-twitter-collection/src/main/scala/org/apache/streams/examples/flink/twitter/collection/FlinkTwitterPostsPipeline.scala +++ b/streams-examples/streams-examples-flink/flink-twitter-collection/src/main/scala/org/apache/streams/examples/flink/twitter/collection/FlinkTwitterPostsPipeline.scala @@ -167,7 +167,7 @@ class FlinkTwitterPostsPipeline(config: TwitterPostsPipelineConfiguration = new if( config.getTest == true ) { keyed_jsons.writeAsText(outPath,FileSystem.WriteMode.OVERWRITE) } else { - keyed_jsons.addSink(fileSink) + keyed_jsons.addSink(fileSink).name("fileSink") } val result: JobExecutionResult = env.execute("FlinkTwitterPostsPipeline") diff --git a/streams-examples/streams-examples-flink/flink-twitter-collection/src/main/scala/org/apache/streams/examples/flink/twitter/collection/FlinkTwitterSpritzerPipeline.scala b/streams-examples/streams-examples-flink/flink-twitter-collection/src/main/scala/org/apache/streams/examples/flink/twitter/collection/FlinkTwitterSpritzerPipeline.scala index 6e38591..6235672 100644 --- a/streams-examples/streams-examples-flink/flink-twitter-collection/src/main/scala/org/apache/streams/examples/flink/twitter/collection/FlinkTwitterSpritzerPipeline.scala +++ b/streams-examples/streams-examples-flink/flink-twitter-collection/src/main/scala/org/apache/streams/examples/flink/twitter/collection/FlinkTwitterSpritzerPipeline.scala @@ -141,7 +141,7 @@ class FlinkTwitterSpritzerPipeline(config: TwitterSpritzerPipelineConfiguration if( config.getTest == true ) { keyed_jsons.writeAsText(outPath,FileSystem.WriteMode.OVERWRITE) } else { - keyed_jsons.addSink(fileSink) + keyed_jsons.addSink(fileSink).name("fileSink") } val result: JobExecutionResult = env.execute("FlinkTwitterPostsPipeline") diff --git a/streams-examples/streams-examples-flink/flink-twitter-collection/src/main/scala/org/apache/streams/examples/flink/twitter/collection/FlinkTwitterUserInformationPipeline.scala b/streams-examples/streams-examples-flink/flink-twitter-collection/src/main/scala/org/apache/streams/examples/flink/twitter/collection/FlinkTwitterUserInformationPipeline.scala index 32cf232..21bc911 100644 --- a/streams-examples/streams-examples-flink/flink-twitter-collection/src/main/scala/org/apache/streams/examples/flink/twitter/collection/FlinkTwitterUserInformationPipeline.scala +++ b/streams-examples/streams-examples-flink/flink-twitter-collection/src/main/scala/org/apache/streams/examples/flink/twitter/collection/FlinkTwitterUserInformationPipeline.scala @@ -170,7 +170,7 @@ class FlinkTwitterUserInformationPipeline(config: TwitterUserInformationPipeline if( config.getTest == true ) { keyed_jsons.writeAsText(outPath,FileSystem.WriteMode.OVERWRITE) } else { - keyed_jsons.addSink(fileSink) + keyed_jsons.addSink(fileSink).name("fileSink") } val result: JobExecutionResult = env.execute("FlinkTwitterUserInformationPipeline")
