From cd109efe8313a790646cd6048627265e025dddc4 Mon Sep 17 00:00:00 2001 From: Michael Marshall Date: Tue, 9 Feb 2021 21:32:05 -0700 Subject: [PATCH] Call method to ensure class is initialized before constructor returns --- .../broker/loadbalance/impl/LinuxBrokerHostUsageImpl.java | 4 +++- 1 file changed, 3 insertions(+), 1 deletion(-) diff --git a/pulsar-broker/src/main/java/org/apache/pulsar/broker/loadbalance/impl/LinuxBrokerHostUsageImpl.java b/pulsar-broker/src/main/java/org/apache/pulsar/broker/loadbalance/impl/LinuxBrokerHostUsageImpl.java index 29aa288a4726b..46ba077683233 100644 --- a/pulsar-broker/src/main/java/org/apache/pulsar/broker/loadbalance/impl/LinuxBrokerHostUsageImpl.java +++ b/pulsar-broker/src/main/java/org/apache/pulsar/broker/loadbalance/impl/LinuxBrokerHostUsageImpl.java @@ -84,7 +84,9 @@ public LinuxBrokerHostUsageImpl(int hostUsageCheckIntervalMin, } this.isCGroupsEnabled = isCGroupsEnabled; - executorService.scheduleAtFixedRate(this::calculateBrokerHostUsage, 0, + // Call now to initialize values before the constructor returns + calculateBrokerHostUsage(); + executorService.scheduleAtFixedRate(this::calculateBrokerHostUsage, hostUsageCheckIntervalMin, hostUsageCheckIntervalMin, TimeUnit.MINUTES); }