bilahepan opened a new issue #10230:
URL: https://github.com/apache/pulsar/issues/10230
**Describe the bug**
The cluster is running normally with an occasional error. Causes the cluster
to be temporarily unavailable.
Pulsar version 2.5.1
**Exception details**
[pulsar-io-22-6] ERROR org.apache.pulsar.broker.service.BacklogQuotaManager
- Failed to read policies data, will apply the default backlog quota:
namespace={tenant}/{namespace}
java.util.concurrent.TimeoutException: null
at
java.util.concurrent.CompletableFuture.timedGet(CompletableFuture.java:1784)
~[?:1.8.0_265]
at
java.util.concurrent.CompletableFuture.get(CompletableFuture.java:1928)
~[?:1.8.0_265]
at
org.apache.pulsar.zookeeper.ZooKeeperDataCache.get(ZooKeeperDataCache.java:97)
~[org.apache.pulsar-pulsar-zookeeper-utils-2.5.1.jar:2.5.1]
at
org.apache.pulsar.broker.service.BacklogQuotaManager.getBacklogQuota(BacklogQuotaManager.java:64)
~[org.apache.pulsar-pulsar-broker-2.5.1.jar:2.5.1]
at
org.apache.pulsar.broker.service.persistent.PersistentTopic.getBacklogQuota(PersistentTopic.java:1786)
~[org.apache.pulsar-pulsar-broker-2.5.1.jar:2.5.1]
at
org.apache.pulsar.broker.service.persistent.PersistentTopic.isBacklogQuotaExceeded(PersistentTopic.java:1796)
~[org.apache.pulsar-pulsar-broker-2.5.1.jar:2.5.1]
at
org.apache.pulsar.broker.service.ServerCnx.lambda$null$20(ServerCnx.java:1014)
~[org.apache.pulsar-pulsar-broker-2.5.1.jar:2.5.1]
at
java.util.concurrent.CompletableFuture.uniAccept(CompletableFuture.java:670)
~[?:1.8.0_265]
at
java.util.concurrent.CompletableFuture.uniAcceptStage(CompletableFuture.java:683)
~[?:1.8.0_265]
at
java.util.concurrent.CompletableFuture.thenAccept(CompletableFuture.java:2010)
~[?:1.8.0_265]
at
org.apache.pulsar.broker.service.ServerCnx.lambda$null$22(ServerCnx.java:1011)
~[org.apache.pulsar-pulsar-broker-2.5.1.jar:2.5.1]
at
java.util.concurrent.CompletableFuture.uniApply(CompletableFuture.java:616)
~[?:1.8.0_265]
at
java.util.concurrent.CompletableFuture.uniApplyStage(CompletableFuture.java:628)
~[?:1.8.0_265]
at
java.util.concurrent.CompletableFuture.thenApply(CompletableFuture.java:1996)
~[?:1.8.0_265]
at
org.apache.pulsar.broker.service.ServerCnx.lambda$handleProducer$24(ServerCnx.java:968)
~[org.apache.pulsar-pulsar-broker-2.5.1.jar:2.5.1]
at
java.util.concurrent.CompletableFuture.uniApply(CompletableFuture.java:616)
[?:1.8.0_265]
at
java.util.concurrent.CompletableFuture.uniApplyStage(CompletableFuture.java:628)
[?:1.8.0_265]
at
java.util.concurrent.CompletableFuture.thenApply(CompletableFuture.java:1996)
[?:1.8.0_265]
at
org.apache.pulsar.broker.service.ServerCnx.handleProducer(ServerCnx.java:958)
[org.apache.pulsar-pulsar-broker-2.5.1.jar:2.5.1]
at
org.apache.pulsar.common.protocol.PulsarDecoder.channelRead(PulsarDecoder.java:189)
[org.apache.pulsar-pulsar-common-2.5.1.jar:2.5.1]
at
io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:377)
[io.netty-netty-transport-4.1.45.Final.jar:4.1.45.Final]
at
io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:363)
[io.netty-netty-transport-4.1.45.Final.jar:4.1.45.Final]
at
io.netty.channel.AbstractChannelHandlerContext.fireChannelRead(AbstractChannelHandlerContext.java:355)
[io.netty-netty-transport-4.1.45.Final.jar:4.1.45.Final]
at
io.netty.handler.flow.FlowControlHandler.dequeue(FlowControlHandler.java:191)
[io.netty-netty-handler-4.1.45.Final.jar:4.1.45.Final]
at
io.netty.handler.flow.FlowControlHandler.channelRead(FlowControlHandler.java:153)
[io.netty-netty-handler-4.1.45.Final.jar:4.1.45.Final]
at
io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:377)
[io.netty-netty-transport-4.1.45.Final.jar:4.1.45.Final]
at
io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:363)
[io.netty-netty-transport-4.1.45.Final.jar:4.1.45.Final]
at
io.netty.channel.AbstractChannelHandlerContext.fireChannelRead(AbstractChannelHandlerContext.java:355)
[io.netty-netty-transport-4.1.45.Final.jar:4.1.45.Final]
at
io.netty.handler.codec.ByteToMessageDecoder.fireChannelRead(ByteToMessageDecoder.java:321)
[io.netty-netty-codec-4.1.45.Final.jar:4.1.45.Final]
at
io.netty.handler.codec.ByteToMessageDecoder.fireChannelRead(ByteToMessageDecoder.java:308)
[io.netty-netty-codec-4.1.45.Final.jar:4.1.45.Final]
at
io.netty.handler.codec.ByteToMessageDecoder.callDecode(ByteToMessageDecoder.java:422)
[io.netty-netty-codec-4.1.45.Final.jar:4.1.45.Final]
at
io.netty.handler.codec.ByteToMessageDecoder.channelRead(ByteToMessageDecoder.java:276)
[io.netty-netty-codec-4.1.45.Final.jar:4.1.45.Final]
at
io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:377)
[io.netty-netty-transport-4.1.45.Final.jar:4.1.45.Final]
at
io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:363)
[io.netty-netty-transport-4.1.45.Final.jar:4.1.45.Final]
at
io.netty.channel.AbstractChannelHandlerContext.fireChannelRead(AbstractChannelHandlerContext.java:355)
[io.netty-netty-transport-4.1.45.Final.jar:4.1.45.Final]
at
io.netty.channel.DefaultChannelPipeline$HeadContext.channelRead(DefaultChannelPipeline.java:1410)
[io.netty-netty-transport-4.1.45.Final.jar:4.1.45.Final]
at
io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:377)
[io.netty-netty-transport-4.1.45.Final.jar:4.1.45.Final]
at
io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:363)
[io.netty-netty-transport-4.1.45.Final.jar:4.1.45.Final]
at
io.netty.channel.DefaultChannelPipeline.fireChannelRead(DefaultChannelPipeline.java:919)
[io.netty-netty-transport-4.1.45.Final.jar:4.1.45.Final]
at
io.netty.channel.epoll.AbstractEpollStreamChannel$EpollStreamUnsafe.epollInReady(AbstractEpollStreamChannel.java:792)
[io.netty-netty-transport-native-epoll-4.1.45.Final-linux-x86_64.jar:4.1.45.Final]
at
io.netty.channel.epoll.EpollEventLoop.processReady(EpollEventLoop.java:475)
[io.netty-netty-transport-native-epoll-4.1.45.Final-linux-x86_64.jar:4.1.45.Final]
at io.netty.channel.epoll.EpollEventLoop.run(EpollEventLoop.java:378)
[io.netty-netty-transport-native-epoll-4.1.45.Final-linux-x86_64.jar:4.1.45.Final]
at
io.netty.util.concurrent.SingleThreadEventExecutor$4.run(SingleThreadEventExecutor.java:989)
[io.netty-netty-common-4.1.45.Final.jar:4.1.45.Final]
at
io.netty.util.internal.ThreadExecutorMap$2.run(ThreadExecutorMap.java:74)
[io.netty-netty-common-4.1.45.Final.jar:4.1.45.Final]
at
io.netty.util.concurrent.FastThreadLocalRunnable.run(FastThreadLocalRunnable.java:30)
[io.netty-netty-common-4.1.45.Final.jar:4.1.45.Final]
at java.lang.Thread.run(Thread.java:748) [?:1.8.0_265]
--
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.
For queries about this service, please contact Infrastructure at:
[email protected]
