GitHub user AbleHou added a comment to the discussion: The registry already
closed when starting broker after using the extensible load balancer
I use image apachepulsar/pulsar-all:3.2.0.
broker error log:
2024-03-11T15:51:03,908+0000 [main] ERROR
org.apache.pulsar.broker.PulsarService - Failed to start Pulsar service:
java.util.concurrent.ExecutionException: java.lang.IllegalStateException: The
registry already closed.
org.apache.pulsar.broker.PulsarServerException:
java.util.concurrent.ExecutionException: java.lang.IllegalStateException: The
registry already closed.
at
org.apache.pulsar.broker.namespace.NamespaceService.registerNamespace(NamespaceService.java:409)
~[org.apache.pulsar-pulsar-broker-3.2.0.jar:3.2.0]
at
org.apache.pulsar.broker.namespace.NamespaceService.registerBootstrapNamespaces(NamespaceService.java:343)
~[org.apache.pulsar-pulsar-broker-3.2.0.jar:3.2.0]
at org.apache.pulsar.broker.PulsarService.start(PulsarService.java:874)
~[org.apache.pulsar-pulsar-broker-3.2.0.jar:3.2.0]
at
org.apache.pulsar.PulsarBrokerStarter$BrokerStarter.start(PulsarBrokerStarter.java:276)
~[org.apache.pulsar-pulsar-broker-3.2.0.jar:3.2.0]
at
org.apache.pulsar.PulsarBrokerStarter.main(PulsarBrokerStarter.java:356)
~[org.apache.pulsar-pulsar-broker-3.2.0.jar:3.2.0]
Caused by: java.util.concurrent.ExecutionException:
java.lang.IllegalStateException: The registry already closed.
at
java.util.concurrent.CompletableFuture.reportGet(CompletableFuture.java:396)
~[?:?]
at
java.util.concurrent.CompletableFuture.get(CompletableFuture.java:2073) ~[?:?]
at
org.apache.pulsar.broker.namespace.NamespaceService.registerNamespace(NamespaceService.java:380)
~[org.apache.pulsar-pulsar-broker-3.2.0.jar:3.2.0]
... 4 more
Caused by: java.lang.IllegalStateException: The registry already closed.
at
org.apache.pulsar.broker.loadbalance.extensions.BrokerRegistryImpl.checkState(BrokerRegistryImpl.java:241)
~[org.apache.pulsar-pulsar-broker-3.2.0.jar:3.2.0]
at
org.apache.pulsar.broker.loadbalance.extensions.BrokerRegistryImpl.lookupAsync(BrokerRegistryImpl.java:159)
~[org.apache.pulsar-pulsar-broker-3.2.0.jar:3.2.0]
at
org.apache.pulsar.broker.loadbalance.extensions.ExtensibleLoadManagerImpl.lambda$getBrokerLookupData$13(ExtensibleLoadManagerImpl.java:524)
~[org.apache.pulsar-pulsar-broker-3.2.0.jar:3.2.0]
at
java.util.concurrent.CompletableFuture.uniComposeStage(CompletableFuture.java:1187)
~[?:?]
at
java.util.concurrent.CompletableFuture.thenCompose(CompletableFuture.java:2309)
~[?:?]
at
org.apache.pulsar.broker.loadbalance.extensions.ExtensibleLoadManagerImpl.getBrokerLookupData(ExtensibleLoadManagerImpl.java:524)
~[org.apache.pulsar-pulsar-broker-3.2.0.jar:3.2.0]
at
org.apache.pulsar.broker.loadbalance.extensions.ExtensibleLoadManagerImpl.lambda$assign$8(ExtensibleLoadManagerImpl.java:473)
~[org.apache.pulsar-pulsar-broker-3.2.0.jar:3.2.0]
at
org.apache.pulsar.broker.loadbalance.extensions.ExtensibleLoadManagerImpl.lambda$dedupeLookupRequest$15(ExtensibleLoadManagerImpl.java:563)
~[org.apache.pulsar-pulsar-broker-3.2.0.jar:3.2.0]
at
java.util.concurrent.ConcurrentHashMap.computeIfAbsent(ConcurrentHashMap.java:1708)
~[?:?]
at
org.apache.pulsar.broker.loadbalance.extensions.ExtensibleLoadManagerImpl.dedupeLookupRequest(ExtensibleLoadManagerImpl.java:562)
~[org.apache.pulsar-pulsar-broker-3.2.0.jar:3.2.0]
at
org.apache.pulsar.broker.loadbalance.extensions.ExtensibleLoadManagerImpl.assign(ExtensibleLoadManagerImpl.java:460)
~[org.apache.pulsar-pulsar-broker-3.2.0.jar:3.2.0]
at
org.apache.pulsar.broker.loadbalance.extensions.ExtensibleLoadManagerImpl.tryAcquiringOwnership(ExtensibleLoadManagerImpl.java:546)
~[org.apache.pulsar-pulsar-broker-3.2.0.jar:3.2.0]
at
org.apache.pulsar.broker.namespace.NamespaceService.registerNamespace(NamespaceService.java:380)
~[org.apache.pulsar-pulsar-broker-3.2.0.jar:3.2.0]
... 4 more
GitHub link:
https://github.com/apache/pulsar/discussions/22244#discussioncomment-8752946
----
This is an automatically sent email for [email protected].
To unsubscribe, please send an email to: [email protected]
