Reduce slave sync interval

84bd6409 · dongeforever · 41373641 · 84bd6409
隐藏空白更改
内联并排

Showing with 1 addition and 1 deletion

broker/src/main/java/org/apache/rocketmq/broker/BrokerController.java ...ain/java/org/apache/rocketmq/broker/BrokerController.java +1 -1

未找到文件。
--- a/broker/src/main/java/org/apache/rocketmq/broker/BrokerController.java
+++ b/broker/src/main/java/org/apache/rocketmq/broker/BrokerController.java
@@ -1049,7 +1049,7 @@ public class BrokerController {
                        log.error("ScheduledTask SlaveSynchronize syncAll error.", e);
                    }
                }
-            }, 1000 * 10, 1000 * 60, TimeUnit.MILLISECONDS);
+            }, 1000 * 3, 1000 * 3, TimeUnit.MILLISECONDS);
        } else {
            //handle the slave synchronise
            if (null != slaveSyncFuture) {