统一flink版本，规范周期开始结束时间字段命名

realtime/hologram-streaming/src/main/java/com/zhht/irn/sink/DirectionEvalSecondSink.java

@@ -31,7 +31,7 @@ public class DirectionEvalSecondSink extends RichSinkFunction<DirectionEvalSecon
         connection = DorisUtils.getConnection();
         String insertSql="insert into app_direction_eval_second_metric" +
                 "(cross_id, lane_id, cycle_order, current_second, acc_arrived_flow, acc_queue_length, acc_stop_count," +
-                " stop_flag_count, statistic_time, cycle_start, cycle_end) values (?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?)";
+                " stop_flag_count, statistic_time, cycle_start_time, cycle_end_time, record_date) values (?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?)";
         insertPstmt = connection.prepareStatement(insertSql);
     }
     @Override
@@ -52,9 +52,10 @@ public class DirectionEvalSecondSink extends RichSinkFunction<DirectionEvalSecon
         insertPstmt.setInt(6, metric.getAccQueueLength());
         insertPstmt.setInt(7, metric.getAccStopCount());
         insertPstmt.setInt(8, metric.getStopFlagCount());
-        insertPstmt.setDate(9, new Date(System.currentTimeMillis()));
+        insertPstmt.setString(9, DateUtils.getTodayTime());
         insertPstmt.setString(10, DateUtils.longToString(metric.getCycleStart(), DateUtils.timeFormat));
         insertPstmt.setString(11, DateUtils.longToString(metric.getCycleEnd(), DateUtils.timeFormat));
+        insertPstmt.setDate(12, new Date(System.currentTimeMillis()));
 
         if(counter < INSERT_BATCH_SIZE) {
             counter ++;

realtime/hologram-streaming/src/main/resources/kafka.properties

 bootstrap.servers=10.100.32.173:9092
 kafka.input.topics=trips_info
-auto.offset.reset=earliest
+auto.offset.reset=latest
 group.id=wuyanfei
\ No newline at end of file

realtime/pom.xml

@@ -54,7 +54,7 @@
 
     <properties>
         <project.build.sourceEncoding>UTF-8</project.build.sourceEncoding>
-        <flink.version>1.12.1</flink.version>
+        <flink.version>1.14.4</flink.version>
         <scala.binary.version>2.12</scala.binary.version>
         <target.java.version>1.8</target.java.version>
         <maven.compiler.source>${target.java.version}</maven.compiler.source>