diff --git a/pom.xml b/pom.xml
index 406346f..17e482f 100644
--- a/pom.xml
+++ b/pom.xml
@@ -17,7 +17,7 @@
         <flink.version>1.13.1</flink.version>
         <hive.version>2.1.1</hive.version>
         <hadoop.version>2.7.1</hadoop.version>
-        <scala.binary.version>2.11</scala.binary.version>
+        <scala.binary.version>2.12</scala.binary.version>
         <jsonpath.version>2.4.0</jsonpath.version>
     </properties>
 
@@ -136,15 +136,15 @@
         </dependency>
 
         <!--<dependency>-->
-            <!--<groupId>org.slf4j</groupId>-->
-            <!--<artifactId>slf4j-api</artifactId>-->
-            <!--<version>1.7.21</version>-->
+        <!--<groupId>org.slf4j</groupId>-->
+        <!--<artifactId>slf4j-api</artifactId>-->
+        <!--<version>1.7.21</version>-->
         <!--</dependency>-->
 
         <!--<dependency>-->
-            <!--<groupId>org.slf4j</groupId>-->
-            <!--<artifactId>slf4j-log4j12</artifactId>-->
-            <!--<version>1.7.21</version>-->
+        <!--<groupId>org.slf4j</groupId>-->
+        <!--<artifactId>slf4j-log4j12</artifactId>-->
+        <!--<version>1.7.21</version>-->
         <!--</dependency>-->
 
         <dependency>
@@ -196,11 +196,11 @@
         </dependency>
 
 
-<!--        <dependency>-->
-<!--            <groupId>org.apache.hadoop</groupId>-->
-<!--            <artifactId>hadoop-hdfs</artifactId>-->
-<!--            <version>${hadoop.version}</version>-->
-<!--        </dependency>-->
+        <!--        <dependency>-->
+        <!--            <groupId>org.apache.hadoop</groupId>-->
+        <!--            <artifactId>hadoop-hdfs</artifactId>-->
+        <!--            <version>${hadoop.version}</version>-->
+        <!--        </dependency>-->
 
         <!-- https://mvnrepository.com/artifact/org.apache.hbase/hbase-client -->
         <dependency>
@@ -337,8 +337,6 @@
             <version>${flink.version}</version>
         </dependency>
 
-
-
         <dependency>
             <groupId>com.geedgenetworks</groupId>
             <artifactId>galaxy</artifactId>
@@ -347,4 +345,4 @@
     </dependencies>
 
 
-</project>
\ No newline at end of file
+</project>
diff --git a/src/main/java/com/zdjizhi/etl/EtlProcessFunction.java b/src/main/java/com/zdjizhi/etl/EtlProcessFunction.java
index 7ffd1d8..c3ebbcc 100644
--- a/src/main/java/com/zdjizhi/etl/EtlProcessFunction.java
+++ b/src/main/java/com/zdjizhi/etl/EtlProcessFunction.java
@@ -6,7 +6,7 @@ import com.zdjizhi.common.FlowWriteConfig;
 import com.zdjizhi.common.DosSketchLog;
 import org.apache.commons.lang3.StringUtils;
 import org.apache.flink.api.java.tuple.Tuple3;
-import org.apache.flink.api.java.tuple.Tuple6;
+import org.apache.flink.api.java.tuple.Tuple7;
 import org.apache.flink.streaming.api.functions.windowing.ProcessWindowFunction;
 import org.apache.flink.streaming.api.windowing.windows.TimeWindow;
 import org.apache.flink.util.Collector;
@@ -44,7 +44,7 @@ public class EtlProcessFunction extends ProcessWindowFunction<DosSketchLog, DosS
     private DosSketchLog getMiddleResult(Tuple3<String,String,Integer> keys,Iterable<DosSketchLog> elements){
 
         DosSketchLog midResuleLog = new DosSketchLog();
-        Tuple6<Long, Long, Long,String,Long,Long> values = sketchAggregate(elements);
+        Tuple7<Long, Long, Long,String,Long,Long,Long> values = sketchAggregate(elements);
         try {
             if (values != null){
                 midResuleLog.setAttack_type(keys.f0);
@@ -56,6 +56,7 @@ public class EtlProcessFunction extends ProcessWindowFunction<DosSketchLog, DosS
                 midResuleLog.setSketch_sessions(values.f0);
                 midResuleLog.setSketch_packets(values.f1);
                 midResuleLog.setSketch_bytes(values.f2);
+                midResuleLog.setCommon_recv_time(values.f6);
                 return midResuleLog;
             }
         } catch (Exception e){
@@ -64,16 +65,23 @@ public class EtlProcessFunction extends ProcessWindowFunction<DosSketchLog, DosS
         return null;
     }
 
-    private Tuple6<Long, Long, Long,String,Long,Long> sketchAggregate(Iterable<DosSketchLog> elements){
+    private Tuple7<Long, Long, Long,String,Long,Long,Long> sketchAggregate(Iterable<DosSketchLog> elements){
         long sessions = 0;
         long packets = 0 ;
         long bytes = 0;
         long startTime = System.currentTimeMillis()/1000;
         long endTime = System.currentTimeMillis()/1000;
         long duration = 0;
+        long recvtime = 0;
         HashSet<String> sourceIpSet = new HashSet<>();
         try {
             for (DosSketchLog newSketchLog : elements){
+               if (recvtime == 0){
+                   recvtime = newSketchLog.getCommon_recv_time();
+               }else if (recvtime > newSketchLog.getCommon_recv_time()){
+                   recvtime = newSketchLog.getCommon_recv_time();
+               }
+                System.out.println(newSketchLog.getCommon_recv_time());
                 String sourceIp = newSketchLog.getSource_ip();
                 if (StringUtils.equals(sourceIp,EMPTY_SOURCE_IP_IPV4) || StringUtils.equals(sourceIp,EMPTY_SOURCE_IP_IPV6)){
                     sessions += newSketchLog.getSketch_sessions();
@@ -88,9 +96,10 @@ public class EtlProcessFunction extends ProcessWindowFunction<DosSketchLog, DosS
                     }
                 }
             }
+
             String sourceIpList = StringUtils.join(sourceIpSet, ",");
-            return Tuple6.of(sessions/ FlowWriteConfig.FLINK_WINDOW_MAX_TIME,packets/ FlowWriteConfig.FLINK_WINDOW_MAX_TIME,
-                    bytes*8/ FlowWriteConfig.FLINK_WINDOW_MAX_TIME,sourceIpList,startTime,duration);
+            return Tuple7.of(sessions/ FlowWriteConfig.FLINK_WINDOW_MAX_TIME,packets/ FlowWriteConfig.FLINK_WINDOW_MAX_TIME,
+                    bytes*8/ FlowWriteConfig.FLINK_WINDOW_MAX_TIME,sourceIpList,startTime,duration,recvtime);
         }catch (Exception e){
             logger.error("聚合中间结果集失败 {}",e);
         }
diff --git a/src/main/java/com/zdjizhi/etl/ParseSketchLog.java b/src/main/java/com/zdjizhi/etl/ParseSketchLog.java
index f00a289..08c91a5 100644
--- a/src/main/java/com/zdjizhi/etl/ParseSketchLog.java
+++ b/src/main/java/com/zdjizhi/etl/ParseSketchLog.java
@@ -44,7 +44,7 @@ public class ParseSketchLog {
             try {
                 if (StringUtil.isNotBlank(s)) {
 
-                    final long recv_time = System.currentTimeMillis();
+                    final long recv_time = System.currentTimeMillis()/1000;
 
                     HashMap<String, Object> sketchSource = JSONObject.parseObject(s, HashMap.class);
                     long sketchStartTime = Long.parseLong(sketchSource.get("sketch_start_time").toString());
diff --git a/src/main/resources/common.properties b/src/main/resources/common.properties
index 5ba8c9f..23e3551 100644
--- a/src/main/resources/common.properties
+++ b/src/main/resources/common.properties
@@ -8,14 +8,14 @@ stream.execution.job.name=DOS-DETECTION-APPLICATION
 kafka.input.parallelism=3
 
 #输入kafka topic名
-kafka.input.topic.name=DOS-SKETCH-RECORD
+kafka.input.topic.name=test
 
 #输入kafka地址
 kafka.input.bootstrap.servers=192.168.44.12:9094
 #kafka.input.bootstrap.servers=192.168.44.11:9094,192.168.44.14:9094,192.168.44.15:9094
 
 #读取kafka group id
-kafka.input.group.id=dos-detection-job-221125-1
+kafka.input.group.id=dos-detection-job-221125-23132
 #kafka.input.group.id=dos-detection-job-210813-1
 
 #发送kafka metrics并行度大小
@@ -30,7 +30,7 @@ kafka.output.event.parallelism=3
 
 #发送kafka event topic名
 #kafka.output.event.topic.name=DOS-EVENT
-kafka.output.event.topic.name=abcd
+kafka.output.event.topic.name=dos-test
 
 #kafka输出地址
 kafka.output.bootstrap.servers=192.168.44.12:9094