This is an automated email from the ASF dual-hosted git repository. sijie pushed a commit to branch master in repository https://gitbox.apache.org/repos/asf/incubator-pulsar.git
The following commit(s) were added to refs/heads/master by this push: new d0f8a40 Precreate readonly path and increase disk usage thresholds for pulsar standalone (#1309) d0f8a40 is described below commit d0f8a40d0834525ac1679cc7a28621ddc23f899e Author: Sijie Guo <guosi...@gmail.com> AuthorDate: Wed Feb 28 22:10:30 2018 -0800 Precreate readonly path and increase disk usage thresholds for pulsar standalone (#1309) --- .../org/apache/pulsar/zookeeper/LocalBookkeeperEnsemble.java | 9 +++++++-- 1 file changed, 7 insertions(+), 2 deletions(-) diff --git a/pulsar-zookeeper-utils/src/main/java/org/apache/pulsar/zookeeper/LocalBookkeeperEnsemble.java b/pulsar-zookeeper-utils/src/main/java/org/apache/pulsar/zookeeper/LocalBookkeeperEnsemble.java index 016e2ad..09a75d0 100644 --- a/pulsar-zookeeper-utils/src/main/java/org/apache/pulsar/zookeeper/LocalBookkeeperEnsemble.java +++ b/pulsar-zookeeper-utils/src/main/java/org/apache/pulsar/zookeeper/LocalBookkeeperEnsemble.java @@ -145,13 +145,15 @@ public class LocalBookkeeperEnsemble { if (zkc.exists("/ledgers/available", false) == null) { zkc.create("/ledgers/available", new byte[0], Ids.OPEN_ACL_UNSAFE, CreateMode.PERSISTENT); } + if (zkc.exists("/ledgers/available/readonly", false) == null) { + zkc.create("/ledgers/available/readonly", new byte[0], Ids.OPEN_ACL_UNSAFE, CreateMode.PERSISTENT); + } // No need to create an entry for each requested bookie anymore as the // BookieServers will register themselves with ZooKeeper on startup. } catch (KeeperException e) { - // TODO Auto-generated catch block LOG.error("Exception while creating znodes", e); } catch (InterruptedException e) { - // TODO Auto-generated catch block + Thread.currentThread().interrupt(); LOG.error("Interrupted while creating znodes", e); } } @@ -232,6 +234,9 @@ public class LocalBookkeeperEnsemble { conf.setFlushInterval(60000); conf.setProperty("journalMaxGroupWaitMSec", 1L); conf.setAdvertisedAddress(advertisedAddress); + // use high disk usage thresholds for standalone + conf.setDiskUsageWarnThreshold(0.9999f); + conf.setDiskUsageThreshold(0.99999f); runZookeeper(1000); initializeZookeper(); -- To stop receiving notification emails like this one, please contact si...@apache.org.