diff options
| author | 李奉超 <[email protected]> | 2024-07-29 09:42:47 +0000 |
|---|---|---|
| committer | 李奉超 <[email protected]> | 2024-07-29 09:42:47 +0000 |
| commit | 7936bb733939c579546a242632816f4128870b7e (patch) | |
| tree | f00f7968858583659de8256e0ec5d227e5bbe0e7 | |
| parent | f3e99838d0f5d19e8e99c0c3d18fbfb5780bca0b (diff) | |
| parent | cc6947ff0508a050ecae1b27b2f284913b9ee883 (diff) | |
测试时设置setParallelism代码删除
See merge request galaxy/tsg_olap/app-protocol-stat-traffic-merge!12
| -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(); |