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> strategyForSession = WatermarkStrategy .>forBoundedOutOfOrderness(Duration.ofSeconds(config.get(WARTERMARK_MAX_ORDERNESS)))