Bläddra i källkod

adq-批处理数据

yumeng 11 månader sedan
förälder
incheckning
17e967e7d2

+ 1 - 1
job-adq/src/main/java/cn/com/ctop/job/adq/data/service/impl/AdqAccountReportServiceImpl.java

@@ -188,7 +188,7 @@ public class AdqAccountReportServiceImpl implements IAdqAccountReportService {
     }
 
 
-    @Scheduled(cron = "*/20 * * * * ?") // 每30秒检查一次
+    @Scheduled(fixedRate = 20000) // 每30秒检查一次
     public void flushIfNeeded() {
         log.info("开始执行账户报表定时批处理任务....");
         synchronized (advertiserReportHourBuffer) {

+ 1 - 1
job-adq/src/main/java/cn/com/ctop/job/adq/data/service/impl/AdqCreativeCreativeReportServiceImpl.java

@@ -216,7 +216,7 @@ public class AdqCreativeCreativeReportServiceImpl implements IAdqCreativeReportS
     }
 
 
-    @Scheduled(cron = "*/30 * * * * ?") // 每30秒检查一次
+    @Scheduled(fixedRate = 30000) // 每30秒检查一次
     public void flushIfNeeded() {
         log.info("开始执行创意报表定时批处理任务....");
         synchronized (creativeReportHourBuffer) {