行车情况sink doris 使用connector

realtime/hologram-streaming/src/main/java/com/zhht/irn/functions/TravelLineSinkInfoFlatMapFunction.java

@@ -31,7 +31,7 @@ public class TravelLineSinkInfoFlatMapFunction implements FlatMapFunction<List<T
            String record_date = sdf2.format(t.getLast_car_inCross_time());
           //  String record_date = "2023-01-09";
 
-           collector.collect(record_date+"\t"+t.getCross_id()+"\t"+statistic_time+"\t"+t.getCycle_begin_time()+"\t"+t.getCycle_end_time()
+           collector.collect(record_date+"\t"+t.getCross_id()+"\t"+statistic_time+"\t"+sdf.format(t.getCycle_begin_time())+"\t"+sdf.format(t.getCycle_end_time())
            +"\t"+t.getLane_id()+"\t"+t.getCycle_id()+"\t"+t.getDirection()+"\t"+t.getFlow_direction()+"\t"+t.getPass_numbers()
            +"\t"+t.getLast_car_inCross_time()+"\t"+t.getAverage_pass_time()+"\t"+t.getAverage_pass_speed()+"\t"+t.getAverage_control_delay()
            +"\t"+t.getAverage_stop_delay()+"\t"+t.getAverage_stop_times()+"\t"+ t.getAverage_car_head_time_gap());