From 8c790354c09b7b79e6cfa0c85f76d7970dd2a94f Mon Sep 17 00:00:00 2001
From: wanglihui <949764788@qq.com>
Date: Fri, 10 Sep 2021 17:35:25 +0800
Subject: [PATCH] =?UTF-8?q?=E4=BF=AE=E6=94=B9=E8=AE=A1=E7=AE=97=E9=80=9F?=
 =?UTF-8?q?=E7=8E=87=E6=96=B9=E5=BC=8F=EF=BC=8C=E4=BD=BF=E7=94=A8session?=
 =?UTF-8?q?=E6=80=BB=E6=95=B0=E9=99=A4=E4=BB=A5=E6=97=B6=E9=97=B4=E7=AA=97?=
 =?UTF-8?q?=E5=8F=A3?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 src/main/java/com/zdjizhi/etl/EtlProcessFunction.java | 4 +++-
 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