From 3198f4ffab051b237aa7692b1451cd933eb80f98 Mon Sep 17 00:00:00 2001
From: pheecian <pheecian@gmail.com>
Date: Tue, 12 May 2020 20:56:13 +0800
Subject: [PATCH] fix autoSkipConf (#6863)

Fixes #6841
Co-authored-by: Xiaopeng Zhang <xiaopengzhang@Xiaopengs-MacBook-Pro.local>
Co-authored-by: Jia Zhai <zhaijia@apache.org>
---
 .../java/org/apache/pulsar/broker/service/BrokerService.java    | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)

diff --git a/pulsar-broker/src/main/java/org/apache/pulsar/broker/service/BrokerService.java b/pulsar-broker/src/main/java/org/apache/pulsar/broker/service/BrokerService.java
index 1734464c40095..490b6f8ba8598 100644
--- a/pulsar-broker/src/main/java/org/apache/pulsar/broker/service/BrokerService.java
+++ b/pulsar-broker/src/main/java/org/apache/pulsar/broker/service/BrokerService.java
@@ -1060,7 +1060,7 @@ public CompletableFuture<ManagedLedgerConfig> getManagedLedgerConfig(TopicName t
             managedLedgerConfig.setLedgerRolloverTimeout(serviceConfig.getManagedLedgerCursorRolloverTimeInSeconds());
             managedLedgerConfig.setRetentionTime(retentionPolicies.getRetentionTimeInMinutes(), TimeUnit.MINUTES);
             managedLedgerConfig.setRetentionSizeInMB(retentionPolicies.getRetentionSizeInMB());
-
+            managedLedgerConfig.setAutoSkipNonRecoverableData(serviceConfig.isAutoSkipNonRecoverableData());
             OffloadPolicies offloadPolicies = policies.map(p -> p.offload_policies).orElse(null);
 
             if (offloadPolicies == null) {