diff options
| -rw-r--r-- | src/main/java/com/zdjizhi/etl/EtlProcessFunction.java | 4 | ||||
| -rw-r--r-- | src/main/resources/common.properties | 2 |
2 files changed, 4 insertions, 2 deletions
diff --git a/src/main/java/com/zdjizhi/etl/EtlProcessFunction.java b/src/main/java/com/zdjizhi/etl/EtlProcessFunction.java index 464b5f6..64881bb 100644 --- a/src/main/java/com/zdjizhi/etl/EtlProcessFunction.java +++ b/src/main/java/com/zdjizhi/etl/EtlProcessFunction.java @@ -80,7 +80,9 @@ public class EtlProcessFunction extends ProcessWindowFunction<DosSketchLog, DosS } } String sourceIpList = StringUtils.join(sourceIpSet, ","); - return Tuple6.of(sessions/cnt/duration,packets/cnt/duration,bytes/cnt/duration,sourceIpList,startTime,duration); +// return Tuple6.of(sessions/cnt/duration,packets/cnt/duration,bytes/cnt/duration,sourceIpList,startTime,duration); + return Tuple6.of(sessions/CommonConfig.FLINK_WINDOW_MAX_TIME,packets/CommonConfig.FLINK_WINDOW_MAX_TIME, + bytes/CommonConfig.FLINK_WINDOW_MAX_TIME,sourceIpList,startTime,duration); }catch (Exception e){ logger.error("聚合中间结果集失败 {}",e); } diff --git a/src/main/resources/common.properties b/src/main/resources/common.properties index 072c787..0c242b5 100644 --- a/src/main/resources/common.properties +++ b/src/main/resources/common.properties @@ -50,7 +50,7 @@ hbase.client.operation.timeout=30000 hbase.client.scanner.timeout.period=30000 ##hbase baseline表名 -hbase.baseline.table.name=ddos_traffic_baselines +hbase.baseline.table.name=dos:ddos_traffic_baselines #读取baseline限制 hbase.baseline.total.num=1000000 |