[pulsar] branch master updated: make bookie ranges stored in path/to/bkdata/ranges (#6082)

[sijie]

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 <hanbo1...@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
 
b/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);