diff --git a/pom.xml b/pom.xml index 43a95bf..c68344a 100644 --- a/pom.xml +++ b/pom.xml @@ -6,7 +6,7 @@ com.zdjizhi flink-dos-detection - 24-08-16 + 24-09-25 flink-dos-detection http://www.example.com @@ -80,7 +80,7 @@ - flink-dos-detection-24-08-16 + flink-dos-detection-24-09-25 org.apache.http diff --git a/src/main/java/com/zdjizhi/function/MetricsAggregationReduce.java b/src/main/java/com/zdjizhi/function/MetricsAggregationReduce.java index fa19c63..628cf48 100644 --- a/src/main/java/com/zdjizhi/function/MetricsAggregationReduce.java +++ b/src/main/java/com/zdjizhi/function/MetricsAggregationReduce.java @@ -20,7 +20,7 @@ public class MetricsAggregationReduce implements ReduceFunction { value1.setEnd_timestamp_ms(value2.getEnd_timestamp_ms()); } value1.getClient_ips().addAll(value2.getClient_ips()); - value2.getClient_countrys().addAll(value2.getClient_countrys()); + value1.getClient_countrys().addAll(value2.getClient_countrys()); return value1; } }