From 5d412890b4728dd1354c0e74f71da3f95ca67125 Mon Sep 17 00:00:00 2001 From: zengqiao Date: Thu, 15 Sep 2022 11:31:25 +0800 Subject: [PATCH] =?UTF-8?q?=E8=B0=83=E6=95=B4=E8=B6=85=E6=97=B6=E6=97=B6?= =?UTF-8?q?=E9=97=B4=E9=85=8D=E7=BD=AE?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../know/streaming/km/task/job/CommunityReassignJobTask.java | 2 +- .../com/xiaojukeji/know/streaming/km/task/job/KMJobTask.java | 2 +- .../streaming/km/task/metadata/SyncBrokerConfigDiffTask.java | 2 +- 3 files changed, 3 insertions(+), 3 deletions(-) diff --git a/km-task/src/main/java/com/xiaojukeji/know/streaming/km/task/job/CommunityReassignJobTask.java b/km-task/src/main/java/com/xiaojukeji/know/streaming/km/task/job/CommunityReassignJobTask.java index 3a01e80c..e655e57d 100644 --- a/km-task/src/main/java/com/xiaojukeji/know/streaming/km/task/job/CommunityReassignJobTask.java +++ b/km-task/src/main/java/com/xiaojukeji/know/streaming/km/task/job/CommunityReassignJobTask.java @@ -16,7 +16,7 @@ import org.springframework.beans.factory.annotation.Autowired; cron = "0 0/1 * * * ? *", autoRegister = true, consensual = ConsensualEnum.BROADCAST, - timeout = 6 * 60) + timeout = 2 * 60) public class CommunityReassignJobTask extends AbstractAsyncCommonDispatchTask { private static final ILog log = LogFactory.getLog(CommunityReassignJobTask.class); diff --git a/km-task/src/main/java/com/xiaojukeji/know/streaming/km/task/job/KMJobTask.java b/km-task/src/main/java/com/xiaojukeji/know/streaming/km/task/job/KMJobTask.java index c0b64e63..debb020c 100644 --- a/km-task/src/main/java/com/xiaojukeji/know/streaming/km/task/job/KMJobTask.java +++ b/km-task/src/main/java/com/xiaojukeji/know/streaming/km/task/job/KMJobTask.java @@ -13,7 +13,7 @@ import org.springframework.beans.factory.annotation.Autowired; cron = "0 0/1 * * * ? *", autoRegister = true, consensual = ConsensualEnum.BROADCAST, - timeout = 6 * 60) + timeout = 2 * 60) public class KMJobTask extends AbstractAsyncCommonDispatchTask { @Autowired diff --git a/km-task/src/main/java/com/xiaojukeji/know/streaming/km/task/metadata/SyncBrokerConfigDiffTask.java b/km-task/src/main/java/com/xiaojukeji/know/streaming/km/task/metadata/SyncBrokerConfigDiffTask.java index 60ffbd84..04838b0f 100644 --- a/km-task/src/main/java/com/xiaojukeji/know/streaming/km/task/metadata/SyncBrokerConfigDiffTask.java +++ b/km-task/src/main/java/com/xiaojukeji/know/streaming/km/task/metadata/SyncBrokerConfigDiffTask.java @@ -28,7 +28,7 @@ import java.util.stream.Collectors; cron = "0 0/1 * * * ? *", autoRegister = true, consensual = ConsensualEnum.BROADCAST, - timeout = 6 * 60) + timeout = 2 * 60) public class SyncBrokerConfigDiffTask extends AbstractAsyncMetadataDispatchTask { protected static final ILog log = LogFactory.getLog(SyncBrokerConfigDiffTask.class);