This is an automated email from the ASF dual-hosted git repository.

rdhabalia pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/pulsar.git


The following commit(s) were added to refs/heads/master by this push:
     new 82166d0  [pulsar-broker] fix ClassCastException at 
ZkIsolatedBookieEnsemblePlacementPolicy (#3917)
82166d0 is described below

commit 82166d0239da3af9c4add7c126fec211d58b4faa
Author: Rajan Dhabalia <[email protected]>
AuthorDate: Wed Mar 27 14:32:43 2019 -0700

    [pulsar-broker] fix ClassCastException at 
ZkIsolatedBookieEnsemblePlacementPolicy (#3917)
---
 .../main/java/org/apache/pulsar/broker/BookKeeperClientFactoryImpl.java | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)

diff --git 
a/pulsar-broker/src/main/java/org/apache/pulsar/broker/BookKeeperClientFactoryImpl.java
 
b/pulsar-broker/src/main/java/org/apache/pulsar/broker/BookKeeperClientFactoryImpl.java
index 7f13912..f15b9a3 100644
--- 
a/pulsar-broker/src/main/java/org/apache/pulsar/broker/BookKeeperClientFactoryImpl.java
+++ 
b/pulsar-broker/src/main/java/org/apache/pulsar/broker/BookKeeperClientFactoryImpl.java
@@ -97,7 +97,7 @@ public class BookKeeperClientFactoryImpl implements 
BookKeeperClientFactory {
                 if (!clientIsolationZkCache.compareAndSet(null, zkc)) {
                     zkc.stop();
                 }
-                bkConf.setProperty(ZooKeeperCache.ZK_CACHE_INSTANCE, 
this.clientIsolationZkCache);
+                bkConf.setProperty(ZooKeeperCache.ZK_CACHE_INSTANCE, 
this.clientIsolationZkCache.get());
             }
         }
 

Reply via email to