调整超时时间配置

Author: zengqiao

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

@@ -16,7 +16,7 @@
         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);
 

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

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

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

@@ -28,7 +28,7 @@
         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);