version 0.89 (清除部分日志)

flink-ad-monitoring/dependency-reduced-pom.xml

@@ -88,7 +88,7 @@
               </filters>
               <transformers>
                 <transformer>
-                  <mainClass>flink.zanxiangnet.ad.monitoring.PlanStatJob</mainClass>
+                  <mainClass>flink.zanxiangnet.ad.monitoring.AdStatJob</mainClass>
                 </transformer>
               </transformers>
             </configuration>

flink-ad-monitoring/pom.xml

@@ -202,7 +202,7 @@ under the License.
                             <transformers>
                                 <transformer
                                         implementation="org.apache.maven.plugins.shade.resource.ManifestResourceTransformer">
-                                    <mainClass>flink.zanxiangnet.ad.monitoring.PlanStatJob</mainClass>
+                                    <mainClass>flink.zanxiangnet.ad.monitoring.AdStatJob</mainClass>
                                 </transformer>
                             </transformers>
                         </configuration>

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

@@ -82,7 +82,6 @@ public class AdMinuteDWDProcess extends ProcessWindowFunction<AdDataOfMinuteODS,
             statODS = adDataOfMinuteODS;
             break;
         }
-        System.out.println("windowCount：" + adDataOfMinuteODSList.size());
         if (statODS == null) {
             return;
         }
@@ -118,7 +117,6 @@ public class AdMinuteDWDProcess extends ProcessWindowFunction<AdDataOfMinuteODS,
         // 聚合当天的全部数据
         AdStatOfMinuteDWD newAdStat = AdStatOfMinuteDWD.reduce(beforeYesterdayDayDWD, yesterdayMinuteDWD, adDataOfMinuteODSList, statODS, lastReduceData, now);
         collector.collect(newAdStat);
-        System.out.println("输出：" + JsonUtil.toString(newAdStat));
         lastReduceState.put(beginDateTime.format(formatForLastReduceKey), newAdStat);
         yesterdayMinuteState.put(statDay, newAdStat);
 

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

@@ -268,7 +268,6 @@ public class CostHourProcess extends ProcessWindowFunction<AdStatOfMinuteDWD, Co
 
     @Override
     public void clear(ProcessWindowFunction<AdStatOfMinuteDWD, CostHourDM, Long, TimeWindow>.Context context) throws Exception {
-        System.out.println("窗口关闭");
     }
 
 }

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

@@ -176,16 +176,15 @@ public class CostMinuteProcess extends ProcessWindowFunction<AdStatOfMinuteDWD,
             CostMinuterDM CostMinuterDM_new = datachange(adStatOfMinuteDWD, costMinuterDM);
 
             collector.collect(CostMinuterDM_new);
-            System.out.println("costminute_输出：" + JsonUtil.toString(CostMinuterDM_new));
+            // System.out.println("costminute_输出：" + JsonUtil.toString(CostMinuterDM_new));
         }
-        System.out.println("costminute_windowCount：" + adStatOfMinuteDWDlist.size());
+        // System.out.println("costminute_windowCount：" + adStatOfMinuteDWDlist.size());
 
 
     }
 
     @Override
     public void clear(ProcessWindowFunction<AdStatOfMinuteDWD, CostMinuterDM, Long, TimeWindow>.Context context) throws Exception {
-        System.out.println("窗口关闭");
     }
 
 }

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

@@ -153,6 +153,5 @@ public class PlanMinuteDWDProcess extends ProcessWindowFunction<AdDataOfMinuteOD
 
     @Override
     public void clear(ProcessWindowFunction<AdDataOfMinuteODS, PlanStatOfMinuteDWD, Long, TimeWindow>.Context context) throws Exception {
-        System.out.println("窗口关闭");
     }
 }