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);