hadesy commented on issue #3630:
URL: https://github.com/apache/pulsar/issues/3630#issuecomment-729601509


   > @wolfstudy @rdhabalia let's create a fix on branch-2.6 and create a 2.6.3 
release.
   
   @sijie any update? we had the same problem on 2.6.2
   ```
   [ForkJoinPool.commonPool-worker-3] ERROR 
org.apache.pulsar.broker.service.persistent.PersistentTopic - 
[persistent://cdc/mysql/test-partition-0] Policies update failed 
org.apache.pulsar.broker.service.BrokerServiceException$ServerMetadataException:
 java.util.concurrent.TimeoutException, scheduled retry in 60 seconds
   java.util.concurrent.CompletionException: 
org.apache.pulsar.broker.service.BrokerServiceException$ServerMetadataException:
 java.util.concurrent.TimeoutException
        at 
java.util.concurrent.CompletableFuture.encodeThrowable(CompletableFuture.java:292)
 ~[?:1.8.0_252]
        at 
java.util.concurrent.CompletableFuture.completeThrowable(CompletableFuture.java:308)
 ~[?:1.8.0_252]
        at 
java.util.concurrent.CompletableFuture.uniAccept(CompletableFuture.java:661) 
~[?:1.8.0_252]
        at 
java.util.concurrent.CompletableFuture.uniAcceptStage(CompletableFuture.java:683)
 ~[?:1.8.0_252]
        at 
java.util.concurrent.CompletableFuture.thenAccept(CompletableFuture.java:2010) 
~[?:1.8.0_252]
        at 
org.apache.pulsar.broker.service.persistent.PersistentTopic.checkReplicationAndRetryOnFailure(PersistentTopic.java:1027)
 ~[org.apache.pulsar-pulsar-broker-2.6.2.jar:2.6.2]
        at 
org.apache.pulsar.broker.service.persistent.PersistentTopic.onPoliciesUpdate(PersistentTopic.java:1844)
 ~[org.apache.pulsar-pulsar-broker-2.6.2.jar:2.6.2]
        at 
org.apache.pulsar.broker.service.BrokerService.lambda$null$59(BrokerService.java:1537)
 ~[org.apache.pulsar-pulsar-broker-2.6.2.jar:2.6.2]
        at java.util.Optional.ifPresent(Optional.java:159) ~[?:1.8.0_252]
        at 
org.apache.pulsar.broker.service.BrokerService.lambda$null$60(BrokerService.java:1537)
 ~[org.apache.pulsar-pulsar-broker-2.6.2.jar:2.6.2]
        at 
java.util.concurrent.CompletableFuture.uniAccept(CompletableFuture.java:670) 
~[?:1.8.0_252]
        at 
java.util.concurrent.CompletableFuture.uniAcceptStage(CompletableFuture.java:683)
 ~[?:1.8.0_252]
        at 
java.util.concurrent.CompletableFuture.thenAccept(CompletableFuture.java:2010) 
~[?:1.8.0_252]
        at 
org.apache.pulsar.broker.service.BrokerService.lambda$onUpdate$61(BrokerService.java:1532)
 ~[org.apache.pulsar-pulsar-broker-2.6.2.jar:2.6.2]
        at 
org.apache.pulsar.common.util.collections.ConcurrentOpenHashMap$Section.forEach(ConcurrentOpenHashMap.java:388)
 ~[org.apache.pulsar-pulsar-common-2.6.2.jar:2.6.2]
        at 
org.apache.pulsar.common.util.collections.ConcurrentOpenHashMap.forEach(ConcurrentOpenHashMap.java:160)
 ~[org.apache.pulsar-pulsar-common-2.6.2.jar:2.6.2]
        at 
org.apache.pulsar.broker.service.BrokerService.onUpdate(BrokerService.java:1528)
 ~[org.apache.pulsar-pulsar-broker-2.6.2.jar:2.6.2]
        at 
org.apache.pulsar.broker.service.BrokerService.onUpdate(BrokerService.java:171) 
~[org.apache.pulsar-pulsar-broker-2.6.2.jar:2.6.2]
        at 
org.apache.pulsar.zookeeper.ZooKeeperDataCache.lambda$4(ZooKeeperDataCache.java:138)
 ~[org.apache.pulsar-pulsar-zookeeper-utils-2.6.2.jar:2.6.2]
        at 
java.util.concurrent.CompletableFuture.uniAccept(CompletableFuture.java:670) 
~[?:1.8.0_252]
        at 
java.util.concurrent.CompletableFuture$UniAccept.tryFire(CompletableFuture.java:646)
 ~[?:1.8.0_252]
        at 
java.util.concurrent.CompletableFuture.postComplete(CompletableFuture.java:488) 
~[?:1.8.0_252]
        at 
java.util.concurrent.CompletableFuture.complete(CompletableFuture.java:1975) 
~[?:1.8.0_252]
        at 
org.apache.pulsar.zookeeper.ZooKeeperCache.lambda$18(ZooKeeperCache.java:386) 
~[org.apache.pulsar-pulsar-zookeeper-utils-2.6.2.jar:2.6.2]
        at 
java.util.concurrent.CompletableFuture.uniAccept(CompletableFuture.java:670) 
~[?:1.8.0_252]
        at 
java.util.concurrent.CompletableFuture$UniAccept.tryFire(CompletableFuture.java:646)
 ~[?:1.8.0_252]
        at 
java.util.concurrent.CompletableFuture.postComplete(CompletableFuture.java:488) 
~[?:1.8.0_252]
        at 
java.util.concurrent.CompletableFuture.complete(CompletableFuture.java:1975) 
~[?:1.8.0_252]
        at 
org.apache.pulsar.zookeeper.ZooKeeperCache.lambda$14(ZooKeeperCache.java:366) 
~[org.apache.pulsar-pulsar-zookeeper-utils-2.6.2.jar:2.6.2]
        at 
java.util.concurrent.ForkJoinTask$RunnableExecuteAction.exec(ForkJoinTask.java:1402)
 [?:1.8.0_252]
        at java.util.concurrent.ForkJoinTask.doExec(ForkJoinTask.java:289) 
[?:1.8.0_252]
        at 
java.util.concurrent.ForkJoinPool$WorkQueue.runTask(ForkJoinPool.java:1056) 
[?:1.8.0_252]
        at java.util.concurrent.ForkJoinPool.runWorker(ForkJoinPool.java:1692) 
[?:1.8.0_252]
        at 
java.util.concurrent.ForkJoinWorkerThread.run(ForkJoinWorkerThread.java:157) 
[?:1.8.0_252]
   Caused by: 
org.apache.pulsar.broker.service.BrokerServiceException$ServerMetadataException:
 java.util.concurrent.TimeoutException
        at 
org.apache.pulsar.broker.service.persistent.PersistentTopic.checkReplication(PersistentTopic.java:1081)
 ~[org.apache.pulsar-pulsar-broker-2.6.2.jar:2.6.2]
        ... 29 more
   Caused by: java.util.concurrent.TimeoutException
        at 
java.util.concurrent.CompletableFuture.timedGet(CompletableFuture.java:1784) 
~[?:1.8.0_252]
        at 
java.util.concurrent.CompletableFuture.get(CompletableFuture.java:1928) 
~[?:1.8.0_252]
        at 
org.apache.pulsar.zookeeper.ZooKeeperDataCache.get(ZooKeeperDataCache.java:97) 
~[org.apache.pulsar-pulsar-zookeeper-utils-2.6.2.jar:2.6.2]
        at 
org.apache.pulsar.broker.service.persistent.PersistentTopic.checkReplication(PersistentTopic.java:1077)
 ~[org.apache.pulsar-pulsar-broker-2.6.2.jar:2.6.2]
        ... 29 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.

For queries about this service, please contact Infrastructure at:
[email protected]


Reply via email to