diff options
Diffstat (limited to 'src')
| -rw-r--r-- | src/main/java/com/zdjizhi/topology/ApplicationProtocolTopology.java | 1 |
1 files changed, 0 insertions, 1 deletions
diff --git a/src/main/java/com/zdjizhi/topology/ApplicationProtocolTopology.java b/src/main/java/com/zdjizhi/topology/ApplicationProtocolTopology.java index 951703c..26111e0 100644 --- a/src/main/java/com/zdjizhi/topology/ApplicationProtocolTopology.java +++ b/src/main/java/com/zdjizhi/topology/ApplicationProtocolTopology.java @@ -51,7 +51,6 @@ public class ApplicationProtocolTopology { } final StreamExecutionEnvironment environment = StreamExecutionEnvironment.getExecutionEnvironment(); - environment.setParallelism(1); ParameterTool tool = ParameterTool.fromPropertiesFile(args[0]); final Configuration config = tool.getConfiguration(); |