8x48/KnowStreaming
1
0
Fork 0
mirror of https://github.com/didi/KnowStreaming.git synced 2026-01-07 15:12:14 +08:00
Code Issues Actions Packages Projects Releases Wiki Activity

调整超时时间配置

Browse Source
This commit is contained in:
zengqiao
2022-09-15 11:31:25 +08:00
parent 1e318a4c40
commit 5d412890b4
3 changed files with 3 additions and 3 deletions
Download Patch File Download Diff File Expand all files Collapse all files

2
km-task/src/main/java/com/xiaojukeji/know/streaming/km/task/job/CommunityReassignJobTask.java
View File

@@ -16,7 +16,7 @@ import org.springframework.beans.factory.annotation.Autowired;
cron = "0 0/1 * * * ? *", cron = "0 0/1 * * * ? *",
autoRegister = true, autoRegister = true,
consensual = ConsensualEnum.BROADCAST, consensual = ConsensualEnum.BROADCAST,
timeout = 6 * 60) timeout = 2 * 60)
public class CommunityReassignJobTask extends AbstractAsyncCommonDispatchTask { public class CommunityReassignJobTask extends AbstractAsyncCommonDispatchTask {
private static final ILog log = LogFactory.getLog(CommunityReassignJobTask.class); private static final ILog log = LogFactory.getLog(CommunityReassignJobTask.class);

2
km-task/src/main/java/com/xiaojukeji/know/streaming/km/task/job/KMJobTask.java
View File

@@ -13,7 +13,7 @@ import org.springframework.beans.factory.annotation.Autowired;
cron = "0 0/1 * * * ? *", cron = "0 0/1 * * * ? *",
autoRegister = true, autoRegister = true,
consensual = ConsensualEnum.BROADCAST, consensual = ConsensualEnum.BROADCAST,
timeout = 6 * 60) timeout = 2 * 60)
public class KMJobTask extends AbstractAsyncCommonDispatchTask { public class KMJobTask extends AbstractAsyncCommonDispatchTask {
@Autowired @Autowired

2
km-task/src/main/java/com/xiaojukeji/know/streaming/km/task/metadata/SyncBrokerConfigDiffTask.java
View File

@@ -28,7 +28,7 @@ import java.util.stream.Collectors;
cron = "0 0/1 * * * ? *", cron = "0 0/1 * * * ? *",
autoRegister = true, autoRegister = true,
consensual = ConsensualEnum.BROADCAST, consensual = ConsensualEnum.BROADCAST,
timeout = 6 * 60) timeout = 2 * 60)
public class SyncBrokerConfigDiffTask extends AbstractAsyncMetadataDispatchTask { public class SyncBrokerConfigDiffTask extends AbstractAsyncMetadataDispatchTask {
protected static final ILog log = LogFactory.getLog(SyncBrokerConfigDiffTask.class); protected static final ILog log = LogFactory.getLog(SyncBrokerConfigDiffTask.class);