Close ZK before canceling future with exception (apache#6228) (apache…

…#6399) Fixes apache#6228
jiazhai · Feb 29, 2020 · e6a631d · e6a631d
1 parent 4f461c3
commit e6a631d
Showing 1 changed file with 1 addition and 0 deletions.
diff --git a/...okeeper-utils/src/main/java/org/apache/pulsar/zookeeper/ZookeeperBkClientFactoryImpl.java b/...okeeper-utils/src/main/java/org/apache/pulsar/zookeeper/ZookeeperBkClientFactoryImpl.java
@@ -55,6 +55,7 @@ public CompletableFuture<ZooKeeper> create(String serverList, SessionType sessio
                         .build();
 
                 if (zk.getState() == States.CONNECTEDREADONLY && sessionType != SessionType.AllowReadOnly) {
+                    zk.close();
                     future.completeExceptionally(new IllegalStateException("Cannot use a read-only session"));
                 }