otmanel31 commented on issue #6599: TimeoutException on some client connected
URL: https://github.com/apache/pulsar/issues/6599#issuecomment-606883304
 
 
   below piece of related standlone cluster:
   
   > 5:47:27.826 [pulsar-ordered-OrderedExecutor-3-0] WARN  
org.apache.pulsar.broker.service.persistent.PersistentTopic - 
[persistent://tenant/namespace/test-0534a909-9e5b-41e8-bb9e-f1de9e7782df] 
Failed to update persistence-policies java.util.concurrent.TimeoutException
   15:47:27.826 [pulsar-ordered-OrderedExecutor-5-0] WARN  
org.apache.pulsar.broker.service.persistent.PersistentTopic - 
[persistent://tenant/namespace/test/data_up-ba67f7f9-9fc1-439b-82e2-6bcdefa280c6]
 Failed to update persistence-policies java.util.concurrent.TimeoutException
   15:47:27.825 [pulsar-ordered-OrderedExecutor-7-0] WARN  
org.apache.pulsar.broker.service.BrokerService - Got exception when reading 
persistence policy for 
persistent://tenant/namespace/test/data_down-418d645b-5e2b-4f17-ac69-cb21245b9e63:
 null
   java.util.concurrent.TimeoutException: null
           at 
java.util.concurrent.CompletableFuture.timedGet(CompletableFuture.java:1784) 
~[?:1.8.0_232]
           at 
java.util.concurrent.CompletableFuture.get(CompletableFuture.java:1928) 
~[?:1.8.0_232]
           at 
org.apache.pulsar.zookeeper.ZooKeeperDataCache.get(ZooKeeperDataCache.java:97) 
~[org.apache.pulsar-pulsar-zookeeper-utils-2.5.0.jar:2.5.0]
           at 
org.apache.pulsar.broker.service.BrokerService.lambda$getManagedLedgerConfig$32(BrokerService.java:922)
 ~[org.apache.pulsar-pulsar-broker-2.5.0.jar:2.5.0]
           at 
org.apache.bookkeeper.mledger.util.SafeRun$2.safeRun(SafeRun.java:49) 
[org.apache.pulsar-managed-ledger-2.5.0.jar:2.5.0]
           at 
org.apache.bookkeeper.common.util.SafeRunnable.run(SafeRunnable.java:36) 
[org.apache.bookkeeper-bookkeeper-common-4.10.0.jar:4.10.0]
           at 
java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1149) 
[?:1.8.0_232]
           at 
java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624) 
[?:1.8.0_232]
           at 
io.netty.util.concurrent.FastThreadLocalRunnable.run(FastThreadLocalRunnable.java:30)
 [io.netty-netty-common-4.1.43.Final.jar:4.1.43.Final]
           at java.lang.Thread.run(Thread.java:748) [?:1.8.0_232]
   15:47:27.826 [pulsar-ordered-OrderedExecutor-7-0] WARN  
org.apache.pulsar.broker.service.persistent.PersistentTopic - 
[persistent://tenant/namespace/test/data_down-418d645b-5e2b-4f17-ac69-cb21245b9e63]
 Failed to update persistence-policies java.util.concurrent.TimeoutException
   15:47:27.832 [pulsar-ordered-OrderedExecutor-6-0] WARN  
org.apache.pulsar.broker.service.BrokerService - Got exception when reading 
persistence policy for 
persistent://tenant/namespace/test/data_up-21c0b99f-2157-439b-bae6-e2e1bc49c145:
 null
   java.util.concurrent.TimeoutException: null
           at 
java.util.concurrent.CompletableFuture.timedGet(CompletableFuture.java:1784) 
~[?:1.8.0_232]
           at 
java.util.concurrent.CompletableFuture.get(CompletableFuture.java:1928) 
~[?:1.8.0_232]
           at 
org.apache.pulsar.zookeeper.ZooKeeperDataCache.get(ZooKeeperDataCache.java:97) 
~[org.apache.pulsar-pulsar-zookeeper-utils-2.5.0.jar:2.5.0]
           at 
org.apache.pulsar.broker.service.BrokerService.lambda$getManagedLedgerConfig$32(BrokerService.java:922)
 ~[org.apache.pulsar-pulsar-broker-2.5.0.jar:2.5.0]
           at 
org.apache.bookkeeper.mledger.util.SafeRun$2.safeRun(SafeRun.java:49) 
[org.apache.pulsar-managed-ledger-2.5.0.jar:2.5.0]
           at 
org.apache.bookkeeper.common.util.SafeRunnable.run(SafeRunnable.java:36) 
[org.apache.bookkeeper-bookkeeper-common-4.10.0.jar:4.10.0]
           at 
java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1149) 
[?:1.8.0_232]
           at 
java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624) 
[?:1.8.0_232]
           at 
io.netty.util.concurrent.FastThreadLocalRunnable.run(FastThreadLocalRunnable.java:30)
 [io.netty-netty-common-4.1.43.Final.jar:4.1.43.Final]
           at java.lang.Thread.run(Thread.java:748) [?:1.8.0_232]
   15:47:27.832 [pulsar-ordered-OrderedExecutor-1-0] WARN  
org.apache.pulsar.broker.service.BrokerService - Got exception when reading 
persistence policy for 
persistent://tenant/namespace/test/data_up-75d3d708-9cb4-4643-b17e-ea3fae1f7e8b:
 null
   java.util.concurrent.TimeoutException: null
           at 
java.util.concurrent.CompletableFuture.timedGet(CompletableFuture.java:1784) 
~[?:1.8.0_232]
           at 
java.util.concurrent.CompletableFuture.get(CompletableFuture.java:1928) 
~[?:1.8.0_232]
           at 
org.apache.pulsar.zookeeper.ZooKeeperDataCache.get(ZooKeeperDataCache.java:97) 
~[org.apache.pulsar-pulsar-zookeeper-utils-2.5.0.jar:2.5.0]
           at 
org.apache.pulsar.broker.service.BrokerService.lambda$getManagedLedgerConfig$32(BrokerService.java:922)
 ~[org.apache.pulsar-pulsar-broker-2.5.0.jar:2.5.0]
           at 
org.apache.bookkeeper.mledger.util.SafeRun$2.safeRun(SafeRun.java:49) 
[org.apache.pulsar-managed-ledger-2.5.0.jar:2.5.0]
           at 
org.apache.bookkeeper.common.util.SafeRunnable.run(SafeRunnable.java:36) 
[org.apache.bookkeeper-bookkeeper-common-4.10.0.jar:4.10.0]
           at 
java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1149) 
[?:1.8.0_232]
           at 
java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624) 
[?:1.8.0_232]
           at 
io.netty.util.concurrent.FastThreadLocalRunnable.run(FastThreadLocalRunnable.java:30)
 [io.netty-netty-common-4.1.43.Final.jar:4.1.43.Final]
           at java.lang.Thread.run(Thread.java:748) [?:1.8.0_232]
   
   .......
   
   > 15:47:27.826 [prometheus-stats-69-1] ERROR 
org.apache.pulsar.broker.service.BacklogQuotaManager - Failed to read policies 
data, will apply the default backlog quota: namespace=tenant/namespace/test
   java.util.concurrent.TimeoutException: null
           at 
java.util.concurrent.CompletableFuture.timedGet(CompletableFuture.java:1784) 
~[?:1.8.0_232]
           at 
java.util.concurrent.CompletableFuture.get(CompletableFuture.java:1928) 
~[?:1.8.0_232]
           at 
org.apache.pulsar.zookeeper.ZooKeeperDataCache.get(ZooKeeperDataCache.java:97) 
~[org.apache.pulsar-pulsar-zookeeper-utils-2.5.0.jar:2.5.0]
           at 
org.apache.pulsar.broker.service.BacklogQuotaManager.getBacklogQuota(BacklogQuotaManager.java:64)
 ~[org.apache.pulsar-pulsar-broker-2.5.0.jar:2.5.0]
           at 
org.apache.pulsar.broker.service.persistent.PersistentTopic.getBacklogQuota(PersistentTopic.java:1746)
 ~[org.apache.pulsar-pulsar-broker-2.5.0.jar:2.5.0]
           at 
org.apache.pulsar.broker.stats.prometheus.NamespaceStatsAggregator.getTopicStats(NamespaceStatsAggregator.java:96)
 ~[org.apache.pulsar-pulsar-broker-2.5.0.jar:2.5.0]
           at 
org.apache.pulsar.broker.stats.prometheus.NamespaceStatsAggregator.lambda$null$0(NamespaceStatsAggregator.java:64)
 ~[org.apache.pulsar-pulsar-broker-2.5.0.jar:2.5.0]
           at 
org.apache.pulsar.common.util.collections.ConcurrentOpenHashMap$Section.forEach(ConcurrentOpenHashMap.java:385)
 ~[org.apache.pulsar-pulsar-common-2.5.0.jar:2.5.0]
           at 
org.apache.pulsar.common.util.collections.ConcurrentOpenHashMap.forEach(ConcurrentOpenHashMap.java:159)
 ~[org.apache.pulsar-pulsar-common-2.5.0.jar:2.5.0]
           at 
org.apache.pulsar.broker.stats.prometheus.NamespaceStatsAggregator.lambda$null$1(NamespaceStatsAggregator.java:63)
 ~[org.apache.pulsar-pulsar-broker-2.5.0.jar:2.5.0]
           at 
org.apache.pulsar.common.util.collections.ConcurrentOpenHashMap$Section.forEach(ConcurrentOpenHashMap.java:385)
 ~[org.apache.pulsar-pulsar-common-2.5.0.jar:2.5.0]
           at 
org.apache.pulsar.common.util.collections.ConcurrentOpenHashMap.forEach(ConcurrentOpenHashMap.java:159)
 ~[org.apache.pulsar-pulsar-common-2.5.0.jar:2.5.0]
           at 
org.apache.pulsar.broker.stats.prometheus.NamespaceStatsAggregator.lambda$generate$2(NamespaceStatsAggregator.java:62)
 ~[org.apache.pulsar-pulsar-broker-2.5.0.jar:2.5.0]
           at 
org.apache.pulsar.common.util.collections.ConcurrentOpenHashMap$Section.forEach(ConcurrentOpenHashMap.java:385)
 ~[org.apache.pulsar-pulsar-common-2.5.0.jar:2.5.0]
           at 
org.apache.pulsar.common.util.collections.ConcurrentOpenHashMap.forEach(ConcurrentOpenHashMap.java:159)
 ~[org.apache.pulsar-pulsar-common-2.5.0.jar:2.5.0]
           at 
org.apache.pulsar.broker.stats.prometheus.NamespaceStatsAggregator.generate(NamespaceStatsAggregator.java:59)
 ~[org.apache.pulsar-pulsar-broker-2.5.0.jar:2.5.0]
           at 
org.apache.pulsar.broker.stats.prometheus.PrometheusMetricsGenerator.generate(PrometheusMetricsGenerator.java:73)
 ~[org.apache.pulsar-pulsar-broker-2.5.0.jar:2.5.0]
           at 
org.apache.pulsar.broker.stats.prometheus.PrometheusMetricsServlet.lambda$doGet$0(PrometheusMetricsServlet.java:70)
 ~[org.apache.pulsar-pulsar-broker-2.5.0.jar:2.5.0]
           at 
org.apache.bookkeeper.mledger.util.SafeRun$1.safeRun(SafeRun.java:32) 
[org.apache.pulsar-managed-ledger-2.5.0.jar:2.5.0]
           at 
org.apache.bookkeeper.common.util.SafeRunnable.run(SafeRunnable.java:36) 
[org.apache.bookkeeper-bookkeeper-common-4.10.0.jar:4.10.0]
           at 
java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:511) 
[?:1.8.0_232]
           at java.util.concurrent.FutureTask.run(FutureTask.java:266) 
[?:1.8.0_232]
           at 
java.util.concurrent.ScheduledThreadPoolExecutor$ScheduledFutureTask.access$201(ScheduledThreadPoolExecutor.java:180)
 [?:1.8.0_232]
           at 
java.util.concurrent.ScheduledThreadPoolExecutor$ScheduledFutureTask.run(ScheduledThreadPoolExecutor.java:293)
 [?:1.8.0_232]
           at 
java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1149) 
[?:1.8.0_232]
           at 
java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624) 
[?:1.8.0_232]
           at 
io.netty.util.concurrent.FastThreadLocalRunnable.run(FastThreadLocalRunnable.java:30)
 [io.netty-netty-common-4.1.43.Final.jar:4.1.43.Final]
           at java.lang.Thread.run(Thread.java:748) [?:1.8.0_232]
   15:47:27.835 [ForkJoinPool.commonPool-worker-11] INFO  
org.apache.pulsar.broker.service.AbstractTopic - Disabling publish throttling 
for persistent://tenant/namespace/test-0176c3dc-2a67-497f-b7d7-878aab5b026e
   15:47:27.838 [ForkJoinPool.commonPool-worker-6] INFO  
org.apache.pulsar.broker.service.persistent.PersistentTopic - 
[persistent://tenant/namespace/test/event-9b3d1eb2-c71c-4245-8b2e-9ba33aa345ed] 
Policies updated successfully
   15:47:27.839 [ForkJoinPool.commonPool-worker-6] INFO  
org.apache.pulsar.broker.service.AbstractTopic - Disabling publish throttling 
for 
persistent://tenant/namespace/test/event-4e5fab7e-73bc-4181-8489-a15794369575
   15:47:27.917 [pulsar-ordered-OrderedExecutor-7-0-EventThread] INFO  
org.apache.pulsar.zookeeper.ZooKeeperDataCache - [State:CONNECTED Timeout:30000 
sessionid:0x1003ef8a17f000a local:/127.0.0.1:36300 
remoteserver:localhost/127.0.0.1:2181 lastZxid:1089571 xid:100 sent:128 
recv:138 queuedpkts:0 pendingresp:0 queuedevents:0] Received ZooKeeper watch 
event: WatchedEvent state:SyncConnected type:NodeDataChanged 
path:/admin/policies/tenant/namespace/test
   15:47:27.927 [pulsar-web-57-14] INFO  
org.apache.pulsar.broker.admin.impl.PersistentTopicsBase - 
[28944862-0c87-4fda-8b19-bcbc132b2d5c] Successfully granted access for role 
cbf2b0e0-abe6-46f6-91da-0692706941e2: [consume] - topic 
persistent://tenant/namespace/test/data_down-ab986469-e65b-45e0-944a-44539c7289f8
   15:47:27.929 [pulsar-web-57-14] INFO  org.eclipse.jetty.server.RequestLog - 
xx.xxx.xxx.xxx - - [23/Mar/2020:15:46:27 +0000] "POST 
/admin/v2/persistent/tenant/namespace/test/data_down-ab986469-e65b-45e0-944a-44539c7289f8/permissions/cbf2b0e0-abe6-46f6-91da-0692706941e2
 HTTP/1.1" 204 0 "-" "Pulsar-Java-v2.4.1" 60008

----------------------------------------------------------------
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:
us...@infra.apache.org


With regards,
Apache Git Services

Reply via email to