You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@kylin.apache.org by sh...@apache.org on 2016/01/29 10:48:24 UTC

kylin git commit: KYLIN-1382 fix “CubeMigrationCLI reports error when migrate cube”

Repository: kylin
Updated Branches:
  refs/heads/2.x-staging 4cdd1a435 -> ca1707ee3


KYLIN-1382 fix “CubeMigrationCLI reports error when migrate cube”

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

Branch: refs/heads/2.x-staging
Commit: ca1707ee3dc821b25fa8ba011f35b6bbed8fd883
Parents: 4cdd1a4
Author: shaofengshi <sh...@apache.org>
Authored: Fri Jan 29 17:48:15 2016 +0800
Committer: shaofengshi <sh...@apache.org>
Committed: Fri Jan 29 17:48:15 2016 +0800

----------------------------------------------------------------------
 .../apache/kylin/storage/hbase/util/CubeMigrationCLI.java    | 8 ++++----
 1 file changed, 4 insertions(+), 4 deletions(-)
----------------------------------------------------------------------


http://git-wip-us.apache.org/repos/asf/kylin/blob/ca1707ee/storage-hbase/src/main/java/org/apache/kylin/storage/hbase/util/CubeMigrationCLI.java
----------------------------------------------------------------------
diff --git a/storage-hbase/src/main/java/org/apache/kylin/storage/hbase/util/CubeMigrationCLI.java b/storage-hbase/src/main/java/org/apache/kylin/storage/hbase/util/CubeMigrationCLI.java
index 88980f4..caf79b2 100644
--- a/storage-hbase/src/main/java/org/apache/kylin/storage/hbase/util/CubeMigrationCLI.java
+++ b/storage-hbase/src/main/java/org/apache/kylin/storage/hbase/util/CubeMigrationCLI.java
@@ -421,8 +421,8 @@ public class CubeMigrationCLI {
                 HTableInterface srcAclHtable = null;
                 HTableInterface destAclHtable = null;
                 try {
-                    srcAclHtable = HBaseConnection.get(srcConfig.getMetadataUrl()).getTable(srcConfig.getMetadataUrlPrefix() + ACL_TABLE_NAME);
-                    destAclHtable = HBaseConnection.get(dstConfig.getMetadataUrl()).getTable(dstConfig.getMetadataUrlPrefix() + ACL_TABLE_NAME);
+                    srcAclHtable = HBaseConnection.get(srcConfig.getStorageUrl()).getTable(srcConfig.getMetadataUrlPrefix() + ACL_TABLE_NAME);
+                    destAclHtable = HBaseConnection.get(dstConfig.getStorageUrl()).getTable(dstConfig.getMetadataUrlPrefix() + ACL_TABLE_NAME);
 
                     // cube acl
                     Result result  = srcAclHtable.get(new Get(Bytes.toBytes(cubeId)));
@@ -504,7 +504,7 @@ public class CubeMigrationCLI {
                 String modelId = (String) opt.params[1];
                 HTableInterface destAclHtable = null;
                 try {
-                    destAclHtable = HBaseConnection.get(dstConfig.getMetadataUrl()).getTable(dstConfig.getMetadataUrlPrefix() + ACL_TABLE_NAME);
+                    destAclHtable = HBaseConnection.get(dstConfig.getStorageUrl()).getTable(dstConfig.getMetadataUrlPrefix() + ACL_TABLE_NAME);
 
                     destAclHtable.delete(new Delete(Bytes.toBytes(cubeId)));
                     destAclHtable.delete(new Delete(Bytes.toBytes(modelId)));
@@ -520,4 +520,4 @@ public class CubeMigrationCLI {
             }
         }
     }
-}
\ No newline at end of file
+}