This is an automated email from the ASF dual-hosted git repository.

penghui pushed a commit to branch branch-2.7
in repository https://gitbox.apache.org/repos/asf/pulsar.git


The following commit(s) were added to refs/heads/branch-2.7 by this push:
     new a19db1d  Branch 2.7: TopicPoliciesTest.testMaxSubscriptionsFailFast 
fails (#10640)
a19db1d is described below

commit a19db1db766d83655a217a91780589cd27b0495c
Author: Enrico Olivelli <[email protected]>
AuthorDate: Fri May 21 15:14:56 2021 +0200

    Branch 2.7: TopicPoliciesTest.testMaxSubscriptionsFailFast fails (#10640)
---
 .../org/apache/pulsar/broker/service/persistent/PersistentTopic.java    | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)

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 d87707a..de70619 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
@@ -696,7 +696,7 @@ public class PersistentTopic extends AbstractTopic 
implements Topic, AddEntryCal
         }).exceptionally(ex -> {
             log.error("[{}] Failed to create subscription: {} error: {}", 
topic, subscriptionName, ex);
             USAGE_COUNT_UPDATER.decrementAndGet(PersistentTopic.this);
-            future.completeExceptionally(new PersistenceException(ex));
+
             if (ex.getCause() instanceof NotAllowedException) {
                 future.completeExceptionally(ex.getCause());
             } else {

Reply via email to