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());
}
}