[pulsar] branch master updated: make defaultOffloader create after offloaderStats overrides. (#16638)

[technoboy]

This is an automated email from the ASF dual-hosted git repository.

technoboy pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/pulsar.git


The following commit(s) were added to refs/heads/master by this push:
     new 73436198b6b make defaultOffloader create after offloaderStats 
overrides. (#16638)
73436198b6b is described below

commit 73436198b6b65c751d83f1ec267f2069fa2e7509
Author: Yan Zhao <horizo...@apache.org>
AuthorDate: Mon Jul 25 21:13:26 2022 +0800

    make defaultOffloader create after offloaderStats overrides. (#16638)
---
 pulsar-broker/src/main/java/org/apache/pulsar/broker/PulsarService.java | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)

diff --git 
a/pulsar-broker/src/main/java/org/apache/pulsar/broker/PulsarService.java 
b/pulsar-broker/src/main/java/org/apache/pulsar/broker/PulsarService.java
index 408e776d66d..e4136c66d5f 100644
--- a/pulsar-broker/src/main/java/org/apache/pulsar/broker/PulsarService.java
+++ b/pulsar-broker/src/main/java/org/apache/pulsar/broker/PulsarService.java
@@ -743,7 +743,6 @@ public class PulsarService implements AutoCloseable, 
ShutdownService {
 
             OffloadPoliciesImpl defaultOffloadPolicies =
                     
OffloadPoliciesImpl.create(this.getConfiguration().getProperties());
-            this.defaultOffloader = 
createManagedLedgerOffloader(defaultOffloadPolicies);
 
             OrderedScheduler offloaderScheduler = 
getOffloaderScheduler(defaultOffloadPolicies);
             int interval = config.getManagedLedgerStatsPeriodSeconds();
@@ -751,6 +750,7 @@ public class PulsarService implements AutoCloseable, 
ShutdownService {
 
             offloaderStats = 
LedgerOffloaderStats.create(config.isExposeManagedLedgerMetricsInPrometheus(),
                     exposeTopicMetrics, offloaderScheduler, interval);
+            this.defaultOffloader = 
createManagedLedgerOffloader(defaultOffloadPolicies);
 
             this.brokerInterceptor = BrokerInterceptors.load(config);
             brokerService.setInterceptor(getBrokerInterceptor());