造数据的 bug

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

@@ -188,7 +188,7 @@ public class AdMinuteDWDProcess extends ProcessWindowFunction<AdDataOfMinuteODS,
         List<String> removeKeys = new ArrayList<>(20);
         Iterator<Map.Entry<String, AdStatOfMinuteDWD>> lastIterator = lastReduceState.iterator();
 
-        String delLastReduceKey = beginDateTime.minusHours(3).format(formatForLastReduceKey);
+        String delLastReduceKey = beginDateTime.minusDays(1).format(formatForLastReduceKey);
         while (lastIterator.hasNext()) {
             Map.Entry<String, AdStatOfMinuteDWD> temp = lastIterator.next();
             if (temp.getKey().compareTo(delLastReduceKey) < 0) {