BewareMyPower commented on issue #23412:
URL: https://github.com/apache/pulsar/issues/23412#issuecomment-2404402088
```
2024-10-10T15:39:22,241 - INFO -
[pulsar-load-manager-1044-1:ServiceUnitStateChannelImpl] - Failed to check
broker:localhost:62035 health
java.util.concurrent.TimeoutException: null
at
java.base/java.util.concurrent.CompletableFuture.timedGet(CompletableFuture.java:1960)
~[?:?]
at
java.base/java.util.concurrent.CompletableFuture.get(CompletableFuture.java:2095)
~[?:?]
at
org.apache.pulsar.broker.loadbalance.extensions.channel.ServiceUnitStateChannelImpl.doCleanup(ServiceUnitStateChannelImpl.java:1505)
~[classes/:?]
at
org.apache.pulsar.broker.loadbalance.extensions.channel.ServiceUnitStateChannelImpl.lambda$scheduleCleanup$44(ServiceUnitStateChannelImpl.java:1341)
~[classes/:?]
at
java.base/java.util.concurrent.CompletableFuture$AsyncRun.run(CompletableFuture.java:1804)
[?:?]
at
java.base/java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:539)
[?:?]
at
java.base/java.util.concurrent.FutureTask.run(FutureTask.java:264) [?:?]
at
java.base/java.util.concurrent.ScheduledThreadPoolExecutor$ScheduledFutureTask.run(ScheduledThreadPoolExecutor.java:304)
[?:?]
at
java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1136)
[?:?]
at
java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:635)
[?:?]
at
io.netty.util.concurrent.FastThreadLocalRunnable.run(FastThreadLocalRunnable.java:30)
[netty-common-4.1.113.Final.jar:4.1.113.Final]
at java.base/java.lang.Thread.run(Thread.java:833) [?:?]
2024-10-10T15:39:22,242 - INFO -
[pulsar-load-manager-1044-1:ServiceUnitStateChannelImpl] - Checked the
broker:localhost:62035 health. Continue the orphan bundle cleanup
2024-10-10T15:39:22,242 - INFO -
[pulsar-load-manager-1044-1:ServiceUnitStateChannelImpl] - Started ownership
cleanup for the inactive broker:localhost:62035
2024-10-10T15:39:22,243 - ERROR -
[pulsar-load-manager-1044-1:ServiceUnitStateChannelImpl] - Failed to flush
java.util.concurrent.ExecutionException:
org.apache.pulsar.client.api.PulsarClientException$AlreadyClosedException: The
consumer 6d028 was already closed when the subscription reader-83ad4355d5 of
the topic persistent://pulsar/system/loadbalance
r-service-unit-state getting the last message id
at
java.base/java.util.concurrent.CompletableFuture.reportGet(CompletableFuture.java:396)
~[?:?]
at
java.base/java.util.concurrent.CompletableFuture.get(CompletableFuture.java:2096)
~[?:?]
at
org.apache.pulsar.broker.loadbalance.extensions.channel.ServiceUnitStateTableViewImpl.flush(ServiceUnitStateTableViewImpl.java:175)
~[classes/:?]
at
org.apache.pulsar.broker.loadbalance.extensions.channel.ServiceUnitStateChannelImpl.doCleanup(ServiceUnitStateChannelImpl.java:1524)
~[classes/:?]
at
org.apache.pulsar.broker.loadbalance.extensions.channel.ServiceUnitStateChannelImpl.lambda$scheduleCleanup$44(ServiceUnitStateChannelImpl.java:1341)
~[classes/:?]
at
java.base/java.util.concurrent.CompletableFuture$AsyncRun.run(CompletableFuture.java:1804)
[?:?]
at
java.base/java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:539)
[?:?]
at
java.base/java.util.concurrent.FutureTask.run(FutureTask.java:264) [?:?]
at
java.base/java.util.concurrent.ScheduledThreadPoolExecutor$ScheduledFutureTask.run(ScheduledThreadPoolExecutor.java:304)
[?:?]
at
java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1136)
[?:?]
at
java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:635)
[?:?]
at
io.netty.util.concurrent.FastThreadLocalRunnable.run(FastThreadLocalRunnable.java:30)
[netty-common-4.1.113.Final.jar:4.1.113.Final]
at java.base/java.lang.Thread.run(Thread.java:833) [?:?]
Caused by:
org.apache.pulsar.client.api.PulsarClientException$AlreadyClosedException: The
consumer 6d028 was already closed when the subscription reader-83ad4355d5 of
the topic persistent://pulsar/system/loadbalancer-service-unit-state getting t
he last message id
at
org.apache.pulsar.client.impl.ConsumerImpl.internalGetLastMessageIdAsync(ConsumerImpl.java:2614)
~[classes/:?]
at
org.apache.pulsar.client.impl.ConsumerImpl.getLastMessageIdAsync(ConsumerImpl.java:2601)
~[classes/:?]
at
org.apache.pulsar.client.impl.ConsumerImpl.getLastMessageIdsAsync(ConsumerImpl.java:2606)
~[classes/:?]
at
org.apache.pulsar.client.impl.ReaderImpl.getLastMessageIdsAsync(ReaderImpl.java:270)
~[classes/:?]
at
org.apache.pulsar.client.impl.TableViewImpl.getLastMessageIdOfNonEmptyTopics(TableViewImpl.java:313)
~[classes/:?]
at
org.apache.pulsar.client.impl.TableViewImpl.lambda$refreshAsync$4(TableViewImpl.java:263)
~[classes/:?]
at
java.base/java.util.concurrent.CompletableFuture.uniComposeStage(CompletableFuture.java:1187)
~[?:?]
at
java.base/java.util.concurrent.CompletableFuture.thenCompose(CompletableFuture.java:2309)
~[?:?]
at
org.apache.pulsar.client.impl.TableViewImpl.refreshAsync(TableViewImpl.java:263)
~[classes/:?]
... 11 more
2024-10-10T15:39:22,243 - ERROR -
[pulsar-load-manager-1044-1:ServiceUnitStateChannelImpl] - Failed to flush the
in-flight non-system bundle override messages.
java.util.concurrent.ExecutionException:
org.apache.pulsar.client.api.PulsarClientException$AlreadyClosedException: The
consumer 6d028 was already closed when the subscription reader-83ad4355d5 of
the topic persistent://pulsar/system/loadbalance
r-service-unit-state getting the last message id
at
java.base/java.util.concurrent.CompletableFuture.reportGet(CompletableFuture.java:396)
~[?:?]
at
java.base/java.util.concurrent.CompletableFuture.get(CompletableFuture.java:2096)
~[?:?]
at
org.apache.pulsar.broker.loadbalance.extensions.channel.ServiceUnitStateTableViewImpl.flush(ServiceUnitStateTableViewImpl.java:175)
~[classes/:?]
at
org.apache.pulsar.broker.loadbalance.extensions.channel.ServiceUnitStateChannelImpl.doCleanup(ServiceUnitStateChannelImpl.java:1545)
~[classes/:?]
at
org.apache.pulsar.broker.loadbalance.extensions.channel.ServiceUnitStateChannelImpl.lambda$scheduleCleanup$44(ServiceUnitStateChannelImpl.java:1341)
~[classes/:?]
at
java.base/java.util.concurrent.CompletableFuture$AsyncRun.run(CompletableFuture.java:1804)
[?:?]
at
java.base/java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:539)
[?:?]
at
java.base/java.util.concurrent.FutureTask.run(FutureTask.java:264) [?:?]
at
java.base/java.util.concurrent.ScheduledThreadPoolExecutor$ScheduledFutureTask.run(ScheduledThreadPoolExecutor.java:304)
[?:?]
at
java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1136)
[?:?]
at
java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:635)
[?:?]
at
io.netty.util.concurrent.FastThreadLocalRunnable.run(FastThreadLocalRunnable.java:30)
[netty-common-4.1.113.Final.jar:4.1.113.Final]
at java.base/java.lang.Thread.run(Thread.java:833) [?:?]
Caused by:
org.apache.pulsar.client.api.PulsarClientException$AlreadyClosedException: The
consumer 6d028 was already closed when the subscription reader-83ad4355d5 of
the topic persistent://pulsar/system/loadbalancer-service-unit-state getting t
he last message id
at
org.apache.pulsar.client.impl.ConsumerImpl.internalGetLastMessageIdAsync(ConsumerImpl.java:2614)
~[classes/:?]
at
org.apache.pulsar.client.impl.ConsumerImpl.getLastMessageIdAsync(ConsumerImpl.java:2601)
~[classes/:?]
at
org.apache.pulsar.client.impl.ConsumerImpl.getLastMessageIdsAsync(ConsumerImpl.java:2606)
~[classes/:?]
at
org.apache.pulsar.client.impl.ReaderImpl.getLastMessageIdsAsync(ReaderImpl.java:270)
~[classes/:?]
at
org.apache.pulsar.client.impl.TableViewImpl.getLastMessageIdOfNonEmptyTopics(TableViewImpl.java:313)
~[classes/:?]
at
org.apache.pulsar.client.impl.TableViewImpl.lambda$refreshAsync$4(TableViewImpl.java:263)
~[classes/:?]
at
java.base/java.util.concurrent.CompletableFuture.uniComposeStage(CompletableFuture.java:1187)
~[?:?]
at
java.base/java.util.concurrent.CompletableFuture.thenCompose(CompletableFuture.java:2309)
~[?:?]
at
org.apache.pulsar.client.impl.TableViewImpl.refreshAsync(TableViewImpl.java:263)
~[classes/:?]
... 11 more
2024-10-10T15:39:22,244 - ERROR -
[pulsar-load-manager-1044-1:ServiceUnitStateChannelImpl] - Failed to flush the
in-flight system bundle override messages.
java.util.concurrent.ExecutionException:
org.apache.pulsar.client.api.PulsarClientException$AlreadyClosedException: The
consumer 6d028 was already closed when the subscription reader-83ad4355d5 of
the topic persistent://pulsar/system/loadbalance
r-service-unit-state getting the last message id
at
java.base/java.util.concurrent.CompletableFuture.reportGet(CompletableFuture.java:396)
~[?:?]
at
java.base/java.util.concurrent.CompletableFuture.get(CompletableFuture.java:2096)
~[?:?]
at
org.apache.pulsar.broker.loadbalance.extensions.channel.ServiceUnitStateTableViewImpl.flush(ServiceUnitStateTableViewImpl.java:175)
~[classes/:?]
at
org.apache.pulsar.broker.loadbalance.extensions.channel.ServiceUnitStateChannelImpl.doCleanup(ServiceUnitStateChannelImpl.java:1569)
~[classes/:?]
at
org.apache.pulsar.broker.loadbalance.extensions.channel.ServiceUnitStateChannelImpl.lambda$scheduleCleanup$44(ServiceUnitStateChannelImpl.java:1341)
~[classes/:?]
at
java.base/java.util.concurrent.CompletableFuture$AsyncRun.run(CompletableFuture.java:1804)
[?:?]
at
java.base/java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:539)
[?:?]
at
java.base/java.util.concurrent.FutureTask.run(FutureTask.java:264) [?:?]
at
java.base/java.util.concurrent.ScheduledThreadPoolExecutor$ScheduledFutureTask.run(ScheduledThreadPoolExecutor.java:304)
[?:?]
at
java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1136)
[?:?]
at
java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:635)
[?:?]
at
io.netty.util.concurrent.FastThreadLocalRunnable.run(FastThreadLocalRunnable.java:30)
[netty-common-4.1.113.Final.jar:4.1.113.Final]
at java.base/java.lang.Thread.run(Thread.java:833) [?:?]
Caused by:
org.apache.pulsar.client.api.PulsarClientException$AlreadyClosedException: The
consumer 6d028 was already closed when the subscription reader-83ad4355d5 of
the topic persistent://pulsar/system/loadbalancer-service-unit-state getting
the last message id
at
org.apache.pulsar.client.impl.ConsumerImpl.internalGetLastMessageIdAsync(ConsumerImpl.java:2614)
~[classes/:?]
at
org.apache.pulsar.client.impl.ConsumerImpl.getLastMessageIdAsync(ConsumerImpl.java:2601)
~[classes/:?]
at
org.apache.pulsar.client.impl.ConsumerImpl.getLastMessageIdsAsync(ConsumerImpl.java:2606)
~[classes/:?]
at
org.apache.pulsar.client.impl.ReaderImpl.getLastMessageIdsAsync(ReaderImpl.java:270)
~[classes/:?]
at
org.apache.pulsar.client.impl.TableViewImpl.getLastMessageIdOfNonEmptyTopics(TableViewImpl.java:313)
~[classes/:?]
at
org.apache.pulsar.client.impl.TableViewImpl.lambda$refreshAsync$4(TableViewImpl.java:263)
~[classes/:?]
at
java.base/java.util.concurrent.CompletableFuture.uniComposeStage(CompletableFuture.java:1187)
~[?:?]
at
java.base/java.util.concurrent.CompletableFuture.thenCompose(CompletableFuture.java:2309)
~[?:?]
at
org.apache.pulsar.client.impl.TableViewImpl.refreshAsync(TableViewImpl.java:263)
~[classes/:?]
... 11 more
```
--
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]
