You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@pulsar.apache.org by zh...@apache.org on 2020/05/12 13:45:08 UTC
[pulsar] 17/17: fix autoSkipConf (#6863)
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 <ph...@gmail.com>
AuthorDate: Tue May 12 20:56:13 2020 +0800
fix autoSkipConf (#6863)
Fixes #6841
Co-authored-by: Xiaopeng Zhang <xi...@Xiaopengs-MacBook-Pro.local>
Co-authored-by: Jia Zhai <zh...@apache.org>
(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) {