You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@kylin.apache.org by ma...@apache.org on 2015/09/07 13:20:57 UTC

[22/28] incubator-kylin git commit: KYLIN-957 prepare for upcoming changes

KYLIN-957 prepare for upcoming changes


Project: http://git-wip-us.apache.org/repos/asf/incubator-kylin/repo
Commit: http://git-wip-us.apache.org/repos/asf/incubator-kylin/commit/0eddcf5a
Tree: http://git-wip-us.apache.org/repos/asf/incubator-kylin/tree/0eddcf5a
Diff: http://git-wip-us.apache.org/repos/asf/incubator-kylin/diff/0eddcf5a

Branch: refs/heads/2.x-staging
Commit: 0eddcf5a8d1125df77ac7b583782b900592908ac
Parents: ec9bbb9
Author: shaofengshi <sh...@apache.org>
Authored: Sun Sep 6 21:29:17 2015 +0800
Committer: shaofengshi <sh...@apache.org>
Committed: Sun Sep 6 21:31:59 2015 +0800

----------------------------------------------------------------------
 .../java/org/apache/kylin/storage/hbase/steps/BulkLoadJob.java     | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)
----------------------------------------------------------------------


http://git-wip-us.apache.org/repos/asf/incubator-kylin/blob/0eddcf5a/storage-hbase/src/main/java/org/apache/kylin/storage/hbase/steps/BulkLoadJob.java
----------------------------------------------------------------------
diff --git a/storage-hbase/src/main/java/org/apache/kylin/storage/hbase/steps/BulkLoadJob.java b/storage-hbase/src/main/java/org/apache/kylin/storage/hbase/steps/BulkLoadJob.java
index ec4a8a9..29e9457 100644
--- a/storage-hbase/src/main/java/org/apache/kylin/storage/hbase/steps/BulkLoadJob.java
+++ b/storage-hbase/src/main/java/org/apache/kylin/storage/hbase/steps/BulkLoadJob.java
@@ -71,7 +71,7 @@ public class BulkLoadJob extends AbstractHadoopJob {
             FsPermission permission = new FsPermission((short) 0777);
             for (HBaseColumnFamilyDesc cf : cubeDesc.getHBaseMapping().getColumnFamily()) {
                 String cfName = cf.getName();
-                Path columnFamilyPath = new Path(input + cfName);
+                Path columnFamilyPath = new Path(input, cfName);
 
                 // File may have already been auto-loaded (in the case of MapR DB)
                 if (fs.exists(columnFamilyPath)) {