|
@@ -87,7 +87,7 @@ public class LowerWeightHostManager extends CommonHostManager {
|
|
|
this.workerHostWeightsMap = new ConcurrentHashMap<>();
|
|
|
this.lock = new ReentrantLock();
|
|
|
this.executorService = Executors.newSingleThreadScheduledExecutor(new NamedThreadFactory("LowerWeightHostManagerExecutor"));
|
|
|
- this.executorService.scheduleWithFixedDelay(new RefreshResourceTask(),35, 40, TimeUnit.SECONDS);
|
|
|
+ this.executorService.scheduleWithFixedDelay(new RefreshResourceTask(),0, 40, TimeUnit.SECONDS);
|
|
|
this.roundRobinHostManager = new RoundRobinHostManager();
|
|
|
this.roundRobinHostManager.setZookeeperNodeManager(getZookeeperNodeManager());
|
|
|
}
|