This is an automated email from the ASF dual-hosted git repository.
penghui 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 aeb5361 Remove duplicate updates (#8198)
aeb5361 is described below
commit aeb5361c34a3e70baab269be6f3f111d3e67bb8a
Author: feynmanlin <[email protected]>
AuthorDate: Fri Oct 9 23:35:46 2020 +0800
Remove duplicate updates (#8198)
### Motivation
Offload has been updated asynchronously in `checkPersistencePolicies()` on
line 1888, and there is no need to update repeatedly.
---
.../org/apache/pulsar/broker/service/persistent/PersistentTopic.java | 4 ----
1 file changed, 4 deletions(-)
diff --git
a/pulsar-broker/src/main/java/org/apache/pulsar/broker/service/persistent/PersistentTopic.java
b/pulsar-broker/src/main/java/org/apache/pulsar/broker/service/persistent/PersistentTopic.java
index 429fbb5..0e16ead 100644
---
a/pulsar-broker/src/main/java/org/apache/pulsar/broker/service/persistent/PersistentTopic.java
+++
b/pulsar-broker/src/main/java/org/apache/pulsar/broker/service/persistent/PersistentTopic.java
@@ -1923,10 +1923,6 @@ public class PersistentTopic extends AbstractTopic
implements Topic, AddEntryCal
if (this.subscribeRateLimiter.isPresent()) {
subscribeRateLimiter.get().onPoliciesUpdate(data);
}
- getManagedLedger().getConfig().setLedgerOffloader(
- brokerService.pulsar().getManagedLedgerOffloader(
- TopicName.get(topic).getNamespaceObject(),
data.offload_policies));
-
return CompletableFuture.allOf(replicationFuture, dedupFuture,
persistentPoliciesFuture);
}