version 0.89 (空值的 bug)

flink-ad-monitoring/src/main/java/flink/zanxiangnet/ad/monitoring/kafka/KafkaComponent.java

@@ -61,7 +61,8 @@ public class KafkaComponent {
                 .setTopics(topic)
                 .setGroupId(groupId)
                 .setProperties(kafkaProps)
-                .setStartingOffsets(OffsetsInitializer.committedOffsets(OffsetResetStrategy.EARLIEST))
+                .setStartingOffsets(OffsetsInitializer.earliest())
+                // .setStartingOffsets(OffsetsInitializer.committedOffsets(OffsetResetStrategy.EARLIEST))
                 .setValueOnlyDeserializer(new SimpleStringSchema())
                 .build();
     }

flink-ad-monitoring/src/main/java/flink/zanxiangnet/ad/monitoring/pojo/entity/AdStatOfHourDWD.java

@@ -1282,6 +1282,12 @@ public class AdStatOfHourDWD {
         BeanUtils.copyProperties(value2, result);
         result.setCreateTime(new Date(createTime));
         if (value1 == null) {
+            result.setCostDeviationRateTotal(value2.getCostDeviationRate());
+            result.setCostDeviationRateDay(value2.getCostDeviationRate());
+            result.setCostDeviationRateHour(value2.getCostDeviationRate());
+            result.setCostTotal(value2.getCost());
+            result.setCostDay(value2.getCost());
+            result.setCostHour(value2.getCost());
             result.setCompensationAmountTotal(value2.getCompensationAmount());
             result.setCompensationAmountDay(value2.getCompensationAmount());
             result.setCompensationAmountHour(value2.getCompensationAmount());

flink-ad-monitoring/src/main/java/flink/zanxiangnet/ad/monitoring/pojo/entity/PlanStatOfHourDWD.java

@@ -1232,6 +1232,12 @@ public class PlanStatOfHourDWD {
             result.setAdIds(adIds);
             result.setAdIdsStr(PlanUtil.adIdsStr(value2.getAdId()));
 
+            result.setCostDeviationRateTotal(value2.getCostDeviationRate());
+            result.setCostDeviationRateDay(value2.getCostDeviationRate());
+            result.setCostDeviationRateHour(value2.getCostDeviationRate());
+            result.setCostTotal(value2.getCost());
+            result.setCostDay(value2.getCost());
+            result.setCostHour(value2.getCost());
             result.setCompensationAmountTotal(value2.getCompensationAmount());
             result.setCompensationAmountDay(value2.getCompensationAmount());
             result.setCompensationAmountHour(value2.getCompensationAmount());