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 12:56:24 UTC
[pulsar] branch master updated: fix autoSkipConf (#6863)
This is an automated email from the ASF dual-hosted git repository.
zhaijia 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 3198f4f fix autoSkipConf (#6863)
3198f4f is described below
commit 3198f4ffab051b237aa7692b1451cd933eb80f98
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>
---
.../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 1734464..490b6f8 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 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) {