This is an automated email from the ASF dual-hosted git repository. zhaijia pushed a commit to branch branch-2.5 in repository https://gitbox.apache.org/repos/asf/pulsar.git
commit 2dae2b5d2ea4eb689f8f181b9a5326398ce1687b Author: pheecian <[email protected]> AuthorDate: Tue May 12 20:56:13 2020 +0800 fix autoSkipConf (#6863) Fixes #6841 Co-authored-by: Xiaopeng Zhang <[email protected]> Co-authored-by: Jia Zhai <[email protected]> (cherry picked from commit 3198f4ffab051b237aa7692b1451cd933eb80f98) --- .../src/main/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 ce040ed..bf10d5a 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 @@ -1049,7 +1049,7 @@ public class BrokerService implements Closeable, ZooKeeperCacheListener<Policies 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) {
