pulsar-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From si...@apache.org
Subject [pulsar] branch master updated: make bookie ranges stored in path/to/bkdata/ranges (#6082)
Date Sat, 25 Jan 2020 03:21:07 GMT
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/pulsar.git

The following commit(s) were added to refs/heads/master by this push:
     new 5ae7a00  make bookie ranges stored in path/to/bkdata/ranges (#6082)
5ae7a00 is described below

commit 5ae7a002edd12c9255f37e4f0b05bf1b374de947
Author: hanbo1990 <hanbo1990@gmail.com>
AuthorDate: Sat Jan 25 04:20:59 2020 +0100

    make bookie ranges stored in path/to/bkdata/ranges (#6082)
    Fixes #5326
    ### Motivation
    After this fix, pulsar will not create data/bookkeeper/ranges in the pulsar library folder
after executing `bin/pulsar standalone --bookkeeper-dir dir1 --zookeeper-dir dir2`. All the
bookie ranges will be stored in bookkeeper's data directory.
    ### Modifications
    Pass `storage.range.store.dirs` to storage server when starting pulsar. Hardcode ranges's
dir to ${path/to/bookie/datadir}/ranges/data, just under bookie.
    ### Verifying this change
    Follow the steps in [issue 5326](https://github.com/apache/pulsar/issues/5326) and start
pulsar with `bin/pulsar standalone --bookkeeper-dir dir1 --zookeeper-dir dir2`
 .../main/java/org/apache/pulsar/zookeeper/LocalBookkeeperEnsemble.java | 3 +++
 1 file changed, 3 insertions(+)

diff --git a/pulsar-zookeeper-utils/src/main/java/org/apache/pulsar/zookeeper/LocalBookkeeperEnsemble.java
index 0a743c8..2658035 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
@@ -310,6 +310,9 @@ public class LocalBookkeeperEnsemble {
         // stream storage port
         conf.setProperty("storageserver.grpc.port", streamStoragePort);
+        // storage server settings
+        conf.setProperty("storage.range.store.dirs", bkDataDirName + "/ranges/data");
         // initialize the stream storage metadata
         ClusterInitializer initializer = new ZkClusterInitializer(zkServers);
         initializer.initializeCluster(metadataServiceUri, 2);

View raw message