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 2e4e52f5b80372f564150eb9955231c5d388f1f8 Author: sblackmon <[email protected]> AuthorDate: Sun Aug 9 11:02:51 2020 -0500 don’t interfere with flink environment-level parallelism --- .../flink/twitter/collection/FlinkTwitterFollowingPipeline.scala | 1 - .../examples/flink/twitter/collection/FlinkTwitterPostsPipeline.scala | 1 - .../flink/twitter/collection/FlinkTwitterUserInformationPipeline.scala | 1 - 3 files changed, 3 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 96a7739..fce134d 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 @@ -120,7 +120,6 @@ class FlinkTwitterFollowingPipeline(config: TwitterFollowingPipelineConfiguratio val env: StreamExecutionEnvironment = streamEnvironment(config) - env.setParallelism(streamsConfig.getParallelism().toInt) env.setStreamTimeCharacteristic(TimeCharacteristic.IngestionTime) env.setNumberOfExecutionRetries(0) 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 aad7f32..94540dd 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 @@ -129,7 +129,6 @@ class FlinkTwitterPostsPipeline(config: TwitterPostsPipelineConfiguration = new val env: StreamExecutionEnvironment = streamEnvironment(config) - env.setParallelism(streamsConfig.getParallelism().toInt) env.setStreamTimeCharacteristic(TimeCharacteristic.IngestionTime) env.setNumberOfExecutionRetries(0) 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 080ce57..eb15556 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 @@ -133,7 +133,6 @@ class FlinkTwitterUserInformationPipeline(config: TwitterUserInformationPipeline val env: StreamExecutionEnvironment = streamEnvironment(config) - env.setParallelism(streamsConfig.getParallelism().toInt) env.setStreamTimeCharacteristic(TimeCharacteristic.IngestionTime) env.setNumberOfExecutionRetries(0)
