gfwleak/galaxy-tsg-olap-dos-detection-job
Archived
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

解决部分source_country为空的问题

Browse Source
This commit is contained in:
wangkuan
2024-09-26 10:18:52 +08:00
parent 79e23c1000
commit 824d2c058f
2 changed files with 3 additions and 3 deletions
Download Patch File Download Diff File Expand all files Collapse all files

4
pom.xml
View File

@@ -6,7 +6,7 @@
<groupId>com.zdjizhi</groupId> <groupId>com.zdjizhi</groupId>
<artifactId>flink-dos-detection</artifactId> <artifactId>flink-dos-detection</artifactId>
<version>24-08-16</version> <version>24-09-25</version>
<name>flink-dos-detection</name> <name>flink-dos-detection</name>
<url>http://www.example.com</url> <url>http://www.example.com</url>
@@ -80,7 +80,7 @@
</goals> </goals>
<configuration> <configuration>
<finalName>flink-dos-detection-24-08-16</finalName> <finalName>flink-dos-detection-24-09-25</finalName>
<relocations> <relocations>
<relocation> <relocation>
<pattern>org.apache.http</pattern> <pattern>org.apache.http</pattern>

2
src/main/java/com/zdjizhi/function/MetricsAggregationReduce.java
View File

@@ -20,7 +20,7 @@ public class MetricsAggregationReduce implements ReduceFunction<DosSketchLog> {
value1.setEnd_timestamp_ms(value2.getEnd_timestamp_ms()); value1.setEnd_timestamp_ms(value2.getEnd_timestamp_ms());
} }
value1.getClient_ips().addAll(value2.getClient_ips()); value1.getClient_ips().addAll(value2.getClient_ips());
value2.getClient_countrys().addAll(value2.getClient_countrys()); value1.getClient_countrys().addAll(value2.getClient_countrys());
return value1; return value1;
} }
} }