You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@pulsar.apache.org by rd...@apache.org on 2019/03/27 21:32:48 UTC
[pulsar] branch master updated: [pulsar-broker] fix
ClassCastException at ZkIsolatedBookieEnsemblePlacementPolicy (#3917)
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 <rd...@apache.org>
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());
}
}