selecdb批处理

job-bytedance/src/main/java/cn/com/ctop/job/bytedance/data/service/impl/BytedanceAccountReportServiceImpl.java

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

job-bytedance/src/main/java/cn/com/ctop/job/bytedance/data/service/impl/BytedancePromoterReportServiceImpl.java

@@ -418,7 +418,7 @@ public class BytedancePromoterReportServiceImpl implements IBytedancePromoterRep
         return promoterReportMapper.getAllList();
     }
 
-    @Scheduled(cron = "*/30 * * * * ?") // 每30秒检查一次
+    @Scheduled(fixedRate = 30000) // 每30秒检查一次
     public void flushIfNeeded() {
         log.info("开始执行广告报表定时批处理任务....");
         synchronized (promoterReportHourBuffer) {