1226 修改日志输出方式

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

@@ -5,7 +5,6 @@ import com.alibaba.druid.pool.DruidPooledConnection;
 
 
 import com.zhht.irn.entity.dto.*;
-import com.zhht.irn.job.TravelSituationAnalysisJobGetCycleData;
 import com.zhht.irn.utils.DruidConnectPoolUtils;
 import org.apache.flink.api.common.state.*;
 import org.apache.flink.api.common.time.Time;
@@ -130,7 +129,7 @@ public class TravelCarInfoCoProcessFunction extends CoProcessFunction<TravelInfo
             List<TravelInfo> lineTravelInfos = crossListMap.get(value.getInCrossLineId());
             //如果，当前车道的数据，积压超过5000条，则进行清理操作
             if(lineTravelInfos.size()>5000){
-                System.out.println("移除积压的数据。。。。");
+                logger.info("移除积压的数据。。。。");
                 List<TravelInfo> travelInfoList = orderByInCrossTime(lineTravelInfos);
                 List<TravelInfo> travelInfoListNew = travelInfoList.subList(500, travelInfoList.size());
                 travelInfoListNew.add(value);