You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@pulsar.apache.org by GitBox <gi...@apache.org> on 2021/08/10 03:53:34 UTC

[GitHub] [pulsar] gaozhangmin opened a new issue #11616: Failed to fence subscription

gaozhangmin opened a new issue #11616:
URL: https://github.com/apache/pulsar/issues/11616


   ```
   23:44:10.613 [BookKeeperClientWorker-OrderedExecutor-16-0] WARN  org.apache.pulsar.broker.admin.impl.PersistentTopicsBase - [null][xxxxxxxxx-partition-2] Failed to reset cursor on subscription xxxxxx to position 4205:250:2
   org.apache.pulsar.broker.service.BrokerServiceException$SubscriptionBusyException: Failed to fence subscription
           at org.apache.pulsar.broker.service.persistent.PersistentSubscription.resetCursor(PersistentSubscription.java:706) ~[org.apache.pulsar-pulsar-broker-2.8.0.jar:2.8.0]
           at org.apache.pulsar.broker.service.persistent.PersistentSubscription.resetCursor(PersistentSubscription.java:700) ~[org.apache.pulsar-pulsar-broker-2.8.0.jar:2.8.0]
           at org.apache.pulsar.broker.admin.impl.PersistentTopicsBase.lambda$internalResetCursorOnPosition$95(PersistentTopicsBase.java:2211) ~[org.apache.pulsar-pulsar-broker-2.8.0.jar:2.8.0]
           at java.util.concurrent.CompletableFuture$UniAccept.tryFire(CompletableFuture.java:714) ~[?:?]
           at java.util.concurrent.CompletableFuture.postComplete(CompletableFuture.java:506) ~[?:?]
           at java.util.concurrent.CompletableFuture.complete(CompletableFuture.java:2073) ~[?:?]
           at org.apache.pulsar.broker.admin.impl.PersistentTopicsBase$2.readEntryComplete(PersistentTopicsBase.java:2266) ~[org.apache.pulsar-pulsar-broker-2.8.0.jar:2.8.0]
           at org.apache.bookkeeper.mledger.impl.EntryCacheImpl.lambda$asyncReadEntry0$0(EntryCacheImpl.java:229) ~[org.apache.pulsar-managed-ledger-2.8.0.jar:2.8.0]
           at java.util.concurrent.CompletableFuture.uniWhenComplete(CompletableFuture.java:859) [?:?]
           at java.util.concurrent.CompletableFuture$UniWhenComplete.tryFire(CompletableFuture.java:837) [?:?]
           at java.util.concurrent.CompletableFuture$Completion.run(CompletableFuture.java:478) [?:?]
           at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1128) [?:?]
           at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:628) [?:?]
           at io.netty.util.concurrent.FastThreadLocalRunnable.run(FastThreadLocalRunnable.java:30) [io.netty-netty-common-4.1.66.Final.jar:4.1.66.Final]
           at java.lang.Thread.run(Thread.java:834) [?:?]
   ```


-- 
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.

To unsubscribe, e-mail: commits-unsubscribe@pulsar.apache.org

For queries about this service, please contact Infrastructure at:
users@infra.apache.org



[GitHub] [pulsar] gaozhangmin closed issue #11616: Failed to fence subscription

Posted by GitBox <gi...@apache.org>.
gaozhangmin closed issue #11616:
URL: https://github.com/apache/pulsar/issues/11616


   


-- 
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.

To unsubscribe, e-mail: commits-unsubscribe@pulsar.apache.org

For queries about this service, please contact Infrastructure at:
users@infra.apache.org