gfwleak/galaxy-tsg-olap-app-protocol-stat-traffic-merge
Archived
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

Merge branch 'develop' into 'master'

Browse Source 
测试时设置setParallelism代码删除

See merge request galaxy/tsg_olap/app-protocol-stat-traffic-merge!12
This commit is contained in:
李奉超
2024-07-29 09:42:47 +00:00
parent f3e99838d0 cc6947ff05
commit 7936bb7339
1 changed files with 0 additions and 1 deletions
Download Patch File Download Diff File Expand all files Collapse all files

1
src/main/java/com/zdjizhi/topology/ApplicationProtocolTopology.java
View File

@@ -51,7 +51,6 @@ public class ApplicationProtocolTopology {
} }
final StreamExecutionEnvironment environment = StreamExecutionEnvironment.getExecutionEnvironment(); final StreamExecutionEnvironment environment = StreamExecutionEnvironment.getExecutionEnvironment();
environment.setParallelism(1);
ParameterTool tool = ParameterTool.fromPropertiesFile(args[0]); ParameterTool tool = ParameterTool.fromPropertiesFile(args[0]);
final Configuration config = tool.getConfiguration(); final Configuration config = tool.getConfiguration();