You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@kylin.apache.org by lu...@apache.org on 2015/06/08 20:22:27 UTC
[04/11] incubator-kylin git commit: added an exists check before
setting column family file permissions
added an exists check before setting column family file permissions
Signed-off-by: Li, Yang <ya...@ebay.com>
Project: http://git-wip-us.apache.org/repos/asf/incubator-kylin/repo
Commit: http://git-wip-us.apache.org/repos/asf/incubator-kylin/commit/02562c0d
Tree: http://git-wip-us.apache.org/repos/asf/incubator-kylin/tree/02562c0d
Diff: http://git-wip-us.apache.org/repos/asf/incubator-kylin/diff/02562c0d
Branch: refs/heads/0.7
Commit: 02562c0dd7c4010726e3d3ada42c49cb279bd68a
Parents: 7427f74
Author: c-horn <ch...@gmail.com>
Authored: Fri May 29 14:46:58 2015 -0400
Committer: Li, Yang <ya...@ebay.com>
Committed: Thu Jun 4 17:21:44 2015 +0800
----------------------------------------------------------------------
.../java/org/apache/kylin/job/hadoop/hbase/BulkLoadJob.java | 7 ++++++-
1 file changed, 6 insertions(+), 1 deletion(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/incubator-kylin/blob/02562c0d/job/src/main/java/org/apache/kylin/job/hadoop/hbase/BulkLoadJob.java
----------------------------------------------------------------------
diff --git a/job/src/main/java/org/apache/kylin/job/hadoop/hbase/BulkLoadJob.java b/job/src/main/java/org/apache/kylin/job/hadoop/hbase/BulkLoadJob.java
index fa3725c..7a4702e 100644
--- a/job/src/main/java/org/apache/kylin/job/hadoop/hbase/BulkLoadJob.java
+++ b/job/src/main/java/org/apache/kylin/job/hadoop/hbase/BulkLoadJob.java
@@ -72,7 +72,12 @@ public class BulkLoadJob extends AbstractHadoopJob {
FsPermission permission = new FsPermission((short) 0777);
for (HBaseColumnFamilyDesc cf : cubeDesc.getHBaseMapping().getColumnFamily()) {
String cfName = cf.getName();
- fs.setPermission(new Path(input + cfName), permission);
+ Path columnFamilyPath = new Path(input + cfName);
+
+ // File may have already been auto-loaded (in the case of MapR DB)
+ if(fs.exists(columnFamilyPath)) {
+ fs.setPermission(columnFamilyPath, permission);
+ }
}
String[] newArgs = new String[2];