lhotari commented on pull request #13069:
URL: https://github.com/apache/pulsar/pull/13069#issuecomment-985309595


   I fixed the test in 
https://github.com/lhotari/pulsar/commits/lh-fix-topic-ownership-assignment-branch-2.8
 . I can now consistently reproduce the issue. It results in error 500 :
   
   ```
   10:22:44.069 [metadata-store-150-1] INFO  
org.apache.pulsar.common.naming.NamespaceBundleFactory - Policy updated for 
namespace public/default, refreshing the bundle cache.
   10:22:44.069 [metadata-store-220-1] INFO  
org.apache.pulsar.common.naming.NamespaceBundleFactory - Policy updated for 
namespace public/default, refreshing the bundle cache.
   10:22:44.069 [metadata-store-80-1] INFO  
org.apache.pulsar.common.naming.NamespaceBundleFactory - Policy updated for 
namespace public/default, refreshing the bundle cache.
   10:22:44.069 [metadata-store-45-1] INFO  
org.apache.pulsar.common.naming.NamespaceBundleFactory - Policy updated for 
namespace public/default, refreshing the bundle cache.
   10:22:44.069 [metadata-store-325-1] INFO  
org.apache.pulsar.common.naming.NamespaceBundleFactory - Policy updated for 
namespace public/default, refreshing the bundle cache.
   10:22:44.069 [metadata-store-185-1] INFO  
org.apache.pulsar.common.naming.NamespaceBundleFactory - Policy updated for 
namespace public/default, refreshing the bundle cache.
   10:22:44.069 [metadata-store-255-1] INFO  
org.apache.pulsar.common.naming.NamespaceBundleFactory - Policy updated for 
namespace public/default, refreshing the bundle cache.
   10:22:44.069 [metadata-store-290-1] INFO  
org.apache.pulsar.common.naming.NamespaceBundleFactory - Policy updated for 
namespace public/default, refreshing the bundle cache.
   10:22:44.069 [metadata-store-115-1] INFO  
org.apache.pulsar.common.naming.NamespaceBundleFactory - Policy updated for 
namespace public/default, refreshing the bundle cache.
   10:22:44.070 [metadata-store-255-1] WARN  
org.apache.pulsar.broker.lookup.TopicLookupBase - Failed to lookup broker for 
topic 
persistent://public/default/lookuptest0e133752-6e62-415f-994b-ef5d9ad57730-0: 
org.apache.pulsar.metadata.api.MetadataStoreException$BadVersionException: 
org.apache.zookeeper.KeeperException$BadVersionException: KeeperErrorCode = 
BadVersion for /admin/local-policies/public/default
   java.util.concurrent.CompletionException: 
org.apache.pulsar.metadata.api.MetadataStoreException$BadVersionException: 
org.apache.zookeeper.KeeperException$BadVersionException: KeeperErrorCode = 
BadVersion for /admin/local-policies/public/default
        at 
java.util.concurrent.CompletableFuture.encodeThrowable(CompletableFuture.java:331)
 ~[?:?]
        at 
java.util.concurrent.CompletableFuture.completeThrowable(CompletableFuture.java:346)
 ~[?:?]
        at 
java.util.concurrent.CompletableFuture$UniApply.tryFire(CompletableFuture.java:632)
 ~[?:?]
        at 
java.util.concurrent.CompletableFuture.postComplete(CompletableFuture.java:506) 
~[?:?]
        at 
java.util.concurrent.CompletableFuture.completeExceptionally(CompletableFuture.java:2088)
 ~[?:?]
        at 
org.apache.pulsar.metadata.impl.ZKMetadataStore.lambda$storePut$15(ZKMetadataStore.java:226)
 ~[pulsar-metadata-2.8.2.jar:2.8.2]
        at 
java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1128) 
[?:?]
        at 
java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:628) 
[?:?]
        at 
io.netty.util.concurrent.FastThreadLocalRunnable.run(FastThreadLocalRunnable.java:30)
 [netty-common-4.1.68.Final.jar:4.1.68.Final]
        at java.lang.Thread.run(Thread.java:829) [?:?]
   Caused by: 
org.apache.pulsar.metadata.api.MetadataStoreException$BadVersionException: 
org.apache.zookeeper.KeeperException$BadVersionException: KeeperErrorCode = 
BadVersion for /admin/local-policies/public/default
        at 
org.apache.pulsar.metadata.impl.ZKMetadataStore.getException(ZKMetadataStore.java:308)
 ~[pulsar-metadata-2.8.2.jar:2.8.2]
        ... 5 more
   Caused by: org.apache.zookeeper.KeeperException$BadVersionException: 
KeeperErrorCode = BadVersion for /admin/local-policies/public/default
        at 
org.apache.zookeeper.KeeperException.create(KeeperException.java:122) 
~[zookeeper-3.6.3.jar:3.6.3]
        at org.apache.zookeeper.KeeperException.create(KeeperException.java:54) 
~[zookeeper-3.6.3.jar:3.6.3]
        at 
org.apache.pulsar.metadata.impl.ZKMetadataStore.getException(ZKMetadataStore.java:304)
 ~[pulsar-metadata-2.8.2.jar:2.8.2]
        ... 5 more
   10:22:44.070 [metadata-store-185-1] WARN  
org.apache.pulsar.broker.lookup.TopicLookupBase - Failed to lookup broker for 
topic 
persistent://public/default/lookuptest0e133752-6e62-415f-994b-ef5d9ad57730-0: 
org.apache.pulsar.metadata.api.MetadataStoreException$BadVersionException: 
org.apache.zookeeper.KeeperException$BadVersionException: KeeperErrorCode = 
BadVersion for /admin/local-policies/public/default
   java.util.concurrent.CompletionException: 
org.apache.pulsar.metadata.api.MetadataStoreException$BadVersionException: 
org.apache.zookeeper.KeeperException$BadVersionException: KeeperErrorCode = 
BadVersion for /admin/local-policies/public/default
        at 
java.util.concurrent.CompletableFuture.encodeThrowable(CompletableFuture.java:331)
 ~[?:?]
        at 
java.util.concurrent.CompletableFuture.completeThrowable(CompletableFuture.java:346)
 ~[?:?]
        at 
java.util.concurrent.CompletableFuture$UniApply.tryFire(CompletableFuture.java:632)
 ~[?:?]
        at 
java.util.concurrent.CompletableFuture.postComplete(CompletableFuture.java:506) 
~[?:?]
        at 
java.util.concurrent.CompletableFuture.completeExceptionally(CompletableFuture.java:2088)
 ~[?:?]
        at 
org.apache.pulsar.metadata.impl.ZKMetadataStore.lambda$storePut$15(ZKMetadataStore.java:226)
 ~[pulsar-metadata-2.8.2.jar:2.8.2]
        at 
java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1128) 
[?:?]
        at 
java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:628) 
[?:?]
        at 
io.netty.util.concurrent.FastThreadLocalRunnable.run(FastThreadLocalRunnable.java:30)
 [netty-common-4.1.68.Final.jar:4.1.68.Final]
        at java.lang.Thread.run(Thread.java:829) [?:?]
   Caused by: 
org.apache.pulsar.metadata.api.MetadataStoreException$BadVersionException: 
org.apache.zookeeper.KeeperException$BadVersionException: KeeperErrorCode = 
BadVersion for /admin/local-policies/public/default
        at 
org.apache.pulsar.metadata.impl.ZKMetadataStore.getException(ZKMetadataStore.java:308)
 ~[pulsar-metadata-2.8.2.jar:2.8.2]
        ... 5 more
   Caused by: org.apache.zookeeper.KeeperException$BadVersionException: 
KeeperErrorCode = BadVersion for /admin/local-policies/public/default
        at 
org.apache.zookeeper.KeeperException.create(KeeperException.java:122) 
~[zookeeper-3.6.3.jar:3.6.3]
        at org.apache.zookeeper.KeeperException.create(KeeperException.java:54) 
~[zookeeper-3.6.3.jar:3.6.3]
        at 
org.apache.pulsar.metadata.impl.ZKMetadataStore.getException(ZKMetadataStore.java:304)
 ~[pulsar-metadata-2.8.2.jar:2.8.2]
        ... 5 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]


Reply via email to