[GitHub] rdhabalia opened a new pull request #593: Local-policies cache should copy global-policy data and return combin?

[git]

rdhabalia opened a new pull request #593: Local-policies cache should copy 
global-policy data and return combin?
URL: https://github.com/apache/incubator-pulsar/pull/593
 
 
   ?ed result
   
   ### Motivation
   
   after creating namespace, if we try to get 
`LocalZooKeeperCacheService.localPolicy()` then it gives below exception and 
doesn't create local-policy and doesn't give correct bundle-data
   
   - `LocalZooKeeperCacheService.policyCache()` overrides `getAsync()` to 
combine global-policy + local-policy data. So, `ZookeeperDataCache` should use 
`getAsync()` in internal sync method such as `get()`
   
   
   ```
   java.util.NoSuchElementException: No value present
        at java.util.Optional.get(Optional.java:135)
        at 
org.apache.pulsar.broker.cache.LocalZooKeeperCacheService.lambda$2(LocalZooKeeperCacheService.java:194)
        at 
java.util.concurrent.CompletableFuture.uniAccept(CompletableFuture.java:656)
        at 
java.util.concurrent.CompletableFuture.uniAcceptStage(CompletableFuture.java:669)
        at 
java.util.concurrent.CompletableFuture.thenAccept(CompletableFuture.java:1997)
        at 
org.apache.pulsar.broker.cache.LocalZooKeeperCacheService.createPolicies(LocalZooKeeperCacheService.java:186)
        at 
org.apache.pulsar.broker.cache.LocalZooKeeperCacheService$2.lambda$0(LocalZooKeeperCacheService.java:91)
        at 
java.util.concurrent.CompletableFuture.uniAccept(CompletableFuture.java:656)
        at 
java.util.concurrent.CompletableFuture.uniAcceptStage(CompletableFuture.java:669)
        at 
java.util.concurrent.CompletableFuture.thenAccept(CompletableFuture.java:1997)
        at 
org.apache.pulsar.broker.cache.LocalZooKeeperCacheService$2.getAsync(LocalZooKeeperCacheService.java:86)
        at 
org.apache.pulsar.common.naming.NamespaceBundleFactory.lambda$0(NamespaceBundleFactory.java:80)
        at 
com.github.benmanes.caffeine.cache.LocalAsyncLoadingCache.lambda$get$2(LocalAsyncLoadingCache.java:126)
   ```
   
   ### Result
   
   `LocalZooKeeperCacheService.localPolicy()` should returns correct result and 
create `local-policy` znode.
   
 
----------------------------------------------------------------
This is an automated message from the Apache Git Service.
To respond to the message, please log on 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