8x48/KnowStreaming
1
0
Fork 0
mirror of https://github.com/didi/KnowStreaming.git synced 2025-12-24 11:52:08 +08:00
Code Issues Actions Packages Projects Releases Wiki Activity

统一定时任务cron格式

Browse Source
This commit is contained in:
xuguang
2022-01-21 13:14:31 +08:00
parent a66aed4a88
commit a49c11f655
2 changed files with 2 additions and 2 deletions
Download Patch File Download Diff File Expand all files Collapse all files

2
kafka-manager-task/src/main/java/com/xiaojukeji/kafka/manager/task/dispatch/biz/CalKafkaTopicBill.java
View File

@@ -25,7 +25,7 @@ import java.util.*;
* @author zengqiao * @author zengqiao
* @date 20/5/11 * @date 20/5/11
*/ */
@CustomScheduled(name = "calKafkaBill", cron = "0 0 1 * * *", threadNum = 1, description = "计算账单") @CustomScheduled(name = "calKafkaBill", cron = "0 0 1 * * ?", threadNum = 1, description = "计算账单")
public class CalKafkaTopicBill extends AbstractScheduledTask<ClusterDO> { public class CalKafkaTopicBill extends AbstractScheduledTask<ClusterDO> {
private static final Logger LOGGER = LoggerFactory.getLogger(CalKafkaTopicBill.class); private static final Logger LOGGER = LoggerFactory.getLogger(CalKafkaTopicBill.class);

2
kafka-manager-task/src/main/java/com/xiaojukeji/kafka/manager/task/dispatch/metrics/collect/CollectAndPublishCGData.java
View File

@@ -31,7 +31,7 @@ import java.util.concurrent.FutureTask;
* @author zengqiao * @author zengqiao
* @date 20/9/14 * @date 20/9/14
*/ */
@CustomScheduled(name = "newCollectAndPublishCGData", cron = "30 0/1 * * * *", threadNum = 10, description = "收集并发布消费者指标数据") @CustomScheduled(name = "newCollectAndPublishCGData", cron = "30 0/1 * * * ?", threadNum = 10, description = "收集并发布消费者指标数据")
public class CollectAndPublishCGData extends AbstractScheduledTask<ClusterDO> { public class CollectAndPublishCGData extends AbstractScheduledTask<ClusterDO> {
private static final Logger LOGGER = LoggerFactory.getLogger(CollectAndPublishCGData.class); private static final Logger LOGGER = LoggerFactory.getLogger(CollectAndPublishCGData.class);