srivatsav commented on PR #17401:
URL: https://github.com/apache/pulsar/pull/17401#issuecomment-1306990837
@lhotari here are the stack traces of both the errors
Pulsar Version - 2.9.2
`WARN org.apache.pulsar.broker.namespace.NamespaceService - The information
about the current leader broker wasn't available. Handling load manager
decisions in a decentralized way.`
```
2022-11-08T09:54:38,651+0000 [pulsar-web-38-4] WARN
org.apache.pulsar.broker.admin.impl.NamespacesBase - [null] Failed to create
namespace ALGRUS/JobSync - already exists
2022-11-08T09:54:38,651+0000 [bookkeeper-ml-scheduler-OrderedScheduler-0-0]
INFO org.apache.pulsar.broker.service.persistent.PersistentSubscription -
[persistent://TQL1US/JobSync/jobevents-ack-partition-0][flink-pulsar-dd2186ba-8355-4536-aaa2-056d7bae6dda]
Successfully disconnected consumers from subscription, proceeding with cursor
reset
2022-11-08T09:54:38,651+0000 [bookkeeper-ml-scheduler-OrderedScheduler-0-0]
INFO org.apache.bookkeeper.mledger.impl.ManagedLedgerImpl -
[TQL1US/JobSync/persistent/jobevents-ack-partition-0] Opened new cursor:
ManagedCursorImpl{ledger=TQL1US/JobSync/persistent/jobevents-ack-partition-0,
name=flink-pulsar-dd2186ba-8355-4536-aaa2-056d7bae6dda, ackPos=3504667:-1,
readPos=3504667:0}
2022-11-08T09:54:38,651+0000 [bookkeeper-ml-scheduler-OrderedScheduler-0-0]
INFO org.apache.bookkeeper.mledger.impl.ManagedCursorImpl -
[TQL1US/JobSync/persistent/jobevents-ack-partition-0] Updated cursor
flink-pulsar-dd2186ba-8355-4536-aaa2-056d7bae6dda with ledger id 3509778
md-position=3504667:-1 rd-position=3504667:0
2022-11-08T09:54:38,649+0000 [pulsar-2-1] WARN
org.apache.pulsar.broker.namespace.NamespaceService - The information about the
current leader broker wasn't available. Handling load manager decisions in a
decentralized way. NamespaceBundle[ASCAUS/JobSync/0x00000000_0x40000000]
2022-11-08T09:54:38,649+0000 [pulsar-2-2] WARN
org.apache.pulsar.broker.namespace.NamespaceService - The information about the
current leader broker wasn't available. Handling load manager decisions in a
decentralized way. NamespaceBundle[AEROUS/JobSync/0xc0000000_0xffffffff]
```
`WARN Failed to acquire ownership for namespace bundle`
```
... 7 more
at
java.util.concurrent.CompletableFuture$UniCompose.tryFire(CompletableFuture.java:1072)
~[?:?]
at
org.apache.pulsar.metadata.coordination.impl.ResourceLockImpl.lambda$doRevalidate$20(ResourceLockImpl.java:297)
~[org.apache.pulsar-pulsar-metadata-2.9.2.jar:2.9.2]
Caused by:
org.apache.pulsar.metadata.api.MetadataStoreException$LockBusyException:
Resource at /namespace/CACIGLOBAL/JobSync/0x00000000_0x40000000 is already
locked
... 17 more
at
java.util.concurrent.CompletableFuture$UniApply.tryFire(CompletableFuture.java:632)
~[?:?]
at
java.util.concurrent.CompletableFuture.completeThrowable(CompletableFuture.java:346)
~[?:?]
at
java.util.concurrent.CompletableFuture.encodeThrowable(CompletableFuture.java:331)
~[?:?]
Caused by: java.util.concurrent.CompletionException:
org.apache.pulsar.metadata.api.MetadataStoreException$LockBusyException:
Resource at /namespace/CACIGLOBAL/JobSync/0x00000000_0x40000000 is already
locked
... 20 more
Caused by: org.apache.pulsar.broker.PulsarServerException: Failed to acquire
ownership for namespace bundle CACIGLOBAL/JobSync/0x00000000_0x40000000
at java.lang.Thread.run(Thread.java:829) [?:?]
at
io.netty.util.concurrent.FastThreadLocalRunnable.run(FastThreadLocalRunnable.java:30)
[io.netty-netty-common-4.1.74.Final.jar:4.1.74.Final]
at
java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:628)
[?:?]
at
java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1128)
[?:?]
at
org.apache.pulsar.metadata.impl.ZKMetadataStore.lambda$get$7(ZKMetadataStore.java:139)
~[org.apache.pulsar-pulsar-metadata-2.9.2.jar:2.9.2]
at
java.util.concurrent.CompletableFuture.complete(CompletableFuture.java:2073)
~[?:?]
at
java.util.concurrent.CompletableFuture.postComplete(CompletableFuture.java:506)
~[?:?]
at
java.util.concurrent.CompletableFuture$UniExceptionally.tryFire(CompletableFuture.java:970)
~[?:?]
at
java.util.concurrent.CompletableFuture.uniExceptionally(CompletableFuture.java:986)
~[?:?]
at
org.apache.pulsar.metadata.coordination.impl.ResourceLockImpl.lambda$acquire$4(ResourceLockImpl.java:134)
~[org.apache.pulsar-pulsar-metadata-2.9.2.jar:2.9.2]
at
java.util.concurrent.CompletableFuture.completeExceptionally(CompletableFuture.java:2088)
~[?:?]
at
java.util.concurrent.CompletableFuture.postComplete(CompletableFuture.java:506)
~[?:?]
at
java.util.concurrent.CompletableFuture$UniExceptionally.tryFire(CompletableFuture.java:970)
~[?:?]
at
java.util.concurrent.CompletableFuture.uniExceptionally(CompletableFuture.java:986)
~[?:?]
at
org.apache.pulsar.metadata.coordination.impl.LockManagerImpl.lambda$acquireLock$2(LockManagerImpl.java:111)
~[org.apache.pulsar-pulsar-metadata-2.9.2.jar:2.9.2]
at
java.util.concurrent.CompletableFuture.completeExceptionally(CompletableFuture.java:2088)
~[?:?]
at
java.util.concurrent.CompletableFuture.postComplete(CompletableFuture.java:506)
~[?:?]
at
java.util.concurrent.CompletableFuture$UniExceptionally.tryFire(CompletableFuture.java:970)
~[?:?]
at
java.util.concurrent.CompletableFuture.uniExceptionally(CompletableFuture.java:986)
~[?:?]
at
org.apache.pulsar.broker.namespace.NamespaceService.lambda$searchForCandidateBroker$15(NamespaceService.java:578)
~[org.apache.pulsar-pulsar-broker-2.9.2.jar:2.9.2]
at
java.util.concurrent.CompletableFuture.completeExceptionally(CompletableFuture.java:2088)
~[?:?]
at
java.util.concurrent.CompletableFuture.postComplete(CompletableFuture.java:506)
~[?:?]
at
java.util.concurrent.CompletableFuture$UniRelay.tryFire(CompletableFuture.java:1019)
~[?:?]
at
java.util.concurrent.CompletableFuture.completeRelay(CompletableFuture.java:376)
~[?:?]
at
java.util.concurrent.CompletableFuture.encodeRelay(CompletableFuture.java:367)
~[?:?]
java.util.concurrent.CompletionException:
org.apache.pulsar.broker.PulsarServerException: Failed to acquire ownership for
namespace bundle CACIGLOBAL/JobSync/0x00000000_0x40000000
```
--
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: [email protected]
For queries about this service, please contact Infrastructure at:
[email protected]
