summaryrefslogtreecommitdiff
diff options
context:
space:
mode:
authorlifengchao <[email protected]>2024-07-23 18:33:04 +0800
committerlifengchao <[email protected]>2024-07-23 18:33:04 +0800
commitc0aba9e81f2bc83ba9849c0f820a6ee9bf51dc39 (patch)
tree6424ec0fe0724b97bba0c237dbdf558279898295
parentf8879f87c9f3298c7bb28e8987657dca38527c2a (diff)
TSG-21885 application_protocol_stat摄入Metric更改为JSON扁平结构
-rw-r--r--src/main/java/com/zdjizhi/topology/ApplicationProtocolLegacyTopology.java2
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)))