version 0.89 (小时流的 bug)

flink-ad-monitoring/src/main/java/flink/zanxiangnet/ad/monitoring/AdStatJob.java

@@ -245,6 +245,7 @@ public class AdStatJob {
                                 }
 
                                 AdStatOfHourDWD newStatData = AdStatOfHourDWD.reduce(lastReduceData, element, now);
+                                historyReduceState.put(newStatData.getStatDay(), newStatData);
                                 collector.collect(newStatData);
                             }
                         });

flink-ad-monitoring/src/main/java/flink/zanxiangnet/ad/monitoring/PlanStatJob.java

@@ -196,6 +196,7 @@ public class PlanStatJob {
                         }
 
                         PlanStatOfHourDWD newStatData = PlanStatOfHourDWD.reduce(lastReduceData, element, now);
+                        historyReduceState.put(newStatData.getStatDay(), newStatData);
                         collector.collect(newStatData);
                     }
                 });