[pulsar] branch master updated: [Broker] modify permission in metadata RocksdbMetadataStore (#15381)

[technoboy]

This is an automated email from the ASF dual-hosted git repository.

technoboy 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 a44315e2817 [Broker] modify permission in metadata 
RocksdbMetadataStore (#15381)
a44315e2817 is described below

commit a44315e2817fa4b7d6928a4f0c5cf43e8355971f
Author: skysiders <64545691+skysid...@users.noreply.github.com>
AuthorDate: Tue Jun 21 15:27:07 2022 +0800

    [Broker] modify permission in metadata RocksdbMetadataStore (#15381)
---
 .../java/org/apache/pulsar/metadata/impl/RocksdbMetadataStore.java  | 6 ++++++
 1 file changed, 6 insertions(+)

diff --git 
a/pulsar-metadata/src/main/java/org/apache/pulsar/metadata/impl/RocksdbMetadataStore.java
 
b/pulsar-metadata/src/main/java/org/apache/pulsar/metadata/impl/RocksdbMetadataStore.java
index 944207eaecc..2d4c0a00bf0 100644
--- 
a/pulsar-metadata/src/main/java/org/apache/pulsar/metadata/impl/RocksdbMetadataStore.java
+++ 
b/pulsar-metadata/src/main/java/org/apache/pulsar/metadata/impl/RocksdbMetadataStore.java
@@ -26,6 +26,8 @@ import java.nio.charset.StandardCharsets;
 import java.nio.file.FileSystems;
 import java.nio.file.Files;
 import java.nio.file.Path;
+import java.nio.file.attribute.PosixFilePermission;
+import java.nio.file.attribute.PosixFilePermissions;
 import java.util.ArrayList;
 import java.util.Comparator;
 import java.util.EnumSet;
@@ -220,6 +222,8 @@ public class RocksdbMetadataStore extends 
AbstractMetadataStore {
         Path dataPath = FileSystems.getDefault().getPath(dataDir);
         try {
             Files.createDirectories(dataPath);
+            Set<PosixFilePermission> perms = 
PosixFilePermissions.fromString("rwxr-x---");
+            Files.setPosixFilePermissions(dataPath, perms);
         } catch (IOException e) {
             throw new MetadataStoreException("Fail to create RocksDB file 
directory", e);
         }
@@ -313,6 +317,8 @@ public class RocksdbMetadataStore extends 
AbstractMetadataStore {
             logPathSetting = FileSystems.getDefault().getPath(logPath + 
"/rocksdb-log");
             Files.createDirectories(logPathSetting);
             options.setDbLogDir(logPathSetting.toString());
+            Set<PosixFilePermission> perms = 
PosixFilePermissions.fromString("rwxr-x---");
+            Files.setPosixFilePermissions(logPathSetting, perms);
         }
 
         // Configure log level