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

TSG-21885 application_protocol_stat摄入Metric更改为JSON扁平结构

Browse Source
This commit is contained in:
lifengchao
2024-07-23 18:33:04 +08:00
parent f8879f87c9
commit c0aba9e81f
1 changed files with 1 additions and 1 deletions
Download Patch File Download Diff File Expand all files Collapse all files

2
src/main/java/com/zdjizhi/topology/ApplicationProtocolLegacyTopology.java
View File

@@ -52,7 +52,7 @@ public class ApplicationProtocolLegacyTopology {
final Configuration config = tool.getConfiguration(); final Configuration config = tool.getConfiguration();
environment.getConfig().setGlobalJobParameters(config); environment.getConfig().setGlobalJobParameters(config);
final MergeConfiguration fusionConfiguration = new MergeConfiguration(config); final MergeConfiguration fusionConfiguration = new MergeConfiguration(config);
//水印 //水印
WatermarkStrategy<Tuple3<Tags, Fields, Long>> strategyForSession = WatermarkStrategy WatermarkStrategy<Tuple3<Tags, Fields, Long>> strategyForSession = WatermarkStrategy
.<Tuple3<Tags, Fields, Long>>forBoundedOutOfOrderness(Duration.ofSeconds(config.get(WARTERMARK_MAX_ORDERNESS))) .<Tuple3<Tags, Fields, Long>>forBoundedOutOfOrderness(Duration.ofSeconds(config.get(WARTERMARK_MAX_ORDERNESS)))