跑天数据的 bug

flink-ad-monitoring/src/main/java/flink/zanxiangnet/ad/monitoring/process/AdDayDWDRollMonthProcess.java

@@ -78,7 +78,6 @@ public class AdDayDWDRollMonthProcess extends KeyedProcessFunction<Long, AdDataO
             try (SqlSession session = sqlSessionFactory.openSession()) {
                 AdStatOfDayDWDMapper mapper = session.getMapper(AdStatOfDayDWDMapper.class);
                 Map<String, AdStatOfDayDWD> historyData = mapper.lastReduceResult(adId, DateUtil.formatLocalDate(LocalDate.now().minusDays(60L)), DateUtil.formatLocalDate(LocalDate.now().minusDays(1L)), 60).stream()
-                        .sorted((o1, o2) -> new Long(o1.getCreateTime().getTime() - o2.getCreateTime().getTime()).intValue())
                         .collect(Collectors.toMap(AdStatOfDayDWD::getStatDay, data -> data, (val1, val2) -> val2));
                 historyReduceState.clear();
                 historyReduceState.putAll(historyData);