HBASE-11311 Secure Bulk Load does not execute chmod 777 on the files

Project: http://git-wip-us.apache.org/repos/asf/hbase/repo
Commit: http://git-wip-us.apache.org/repos/asf/hbase/commit/04db3c37
Tree: http://git-wip-us.apache.org/repos/asf/hbase/tree/04db3c37
Diff: http://git-wip-us.apache.org/repos/asf/hbase/diff/04db3c37

Branch: refs/heads/0.98
Commit: 04db3c37620a66fdcce35ebf4ce36d5785a9f4a9
Parents: 4980a67
Author: Matteo Bertozzi <[email protected]>
Authored: Mon Jun 9 22:30:19 2014 +0100
Committer: Matteo Bertozzi <[email protected]>
Committed: Mon Jun 9 22:31:47 2014 +0100

----------------------------------------------------------------------
 .../hadoop/hbase/security/access/SecureBulkLoadEndpoint.java     | 4 ++++
 1 file changed, 4 insertions(+)
----------------------------------------------------------------------


http://git-wip-us.apache.org/repos/asf/hbase/blob/04db3c37/hbase-server/src/main/java/org/apache/hadoop/hbase/security/access/SecureBulkLoadEndpoint.java
----------------------------------------------------------------------
diff --git 
a/hbase-server/src/main/java/org/apache/hadoop/hbase/security/access/SecureBulkLoadEndpoint.java
 
b/hbase-server/src/main/java/org/apache/hadoop/hbase/security/access/SecureBulkLoadEndpoint.java
index 1ce5a50..d41ec0c 100644
--- 
a/hbase-server/src/main/java/org/apache/hadoop/hbase/security/access/SecureBulkLoadEndpoint.java
+++ 
b/hbase-server/src/main/java/org/apache/hadoop/hbase/security/access/SecureBulkLoadEndpoint.java
@@ -250,6 +250,10 @@ public class SecureBulkLoadEndpoint extends 
SecureBulkLoadService
             Configuration conf = env.getConfiguration();
             fs = FileSystem.get(conf);
             for(Pair<byte[], String> el: familyPaths) {
+              Path p = new Path(el.getSecond());
+              LOG.trace("Setting permission for: " + p);
+              fs.setPermission(p, PERM_ALL_ACCESS);
+
               Path stageFamily = new Path(bulkToken, 
Bytes.toString(el.getFirst()));
               if(!fs.exists(stageFamily)) {
                 fs.mkdirs(stageFamily);

Reply via email to