diff options
| author | lifengchao <[email protected]> | 2024-07-23 18:33:04 +0800 |
|---|---|---|
| committer | lifengchao <[email protected]> | 2024-07-23 18:33:04 +0800 |
| commit | c0aba9e81f2bc83ba9849c0f820a6ee9bf51dc39 (patch) | |
| tree | 6424ec0fe0724b97bba0c237dbdf558279898295 | |
| parent | f8879f87c9f3298c7bb28e8987657dca38527c2a (diff) | |
TSG-21885 application_protocol_stat摄入Metric更改为JSON扁平结构
| -rw-r--r-- | src/main/java/com/zdjizhi/topology/ApplicationProtocolLegacyTopology.java | 2 |
1 files changed, 1 insertions, 1 deletions
diff --git a/src/main/java/com/zdjizhi/topology/ApplicationProtocolLegacyTopology.java b/src/main/java/com/zdjizhi/topology/ApplicationProtocolLegacyTopology.java index d91f1be..cc7ca0a 100644 --- a/src/main/java/com/zdjizhi/topology/ApplicationProtocolLegacyTopology.java +++ b/src/main/java/com/zdjizhi/topology/ApplicationProtocolLegacyTopology.java @@ -52,7 +52,7 @@ public class ApplicationProtocolLegacyTopology { final Configuration config = tool.getConfiguration(); environment.getConfig().setGlobalJobParameters(config); final MergeConfiguration fusionConfiguration = new MergeConfiguration(config); - + //水印 WatermarkStrategy<Tuple3<Tags, Fields, Long>> strategyForSession = WatermarkStrategy .<Tuple3<Tags, Fields, Long>>forBoundedOutOfOrderness(Duration.ofSeconds(config.get(WARTERMARK_MAX_ORDERNESS))) |
