You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@kylin.apache.org by li...@apache.org on 2017/04/17 11:44:03 UTC
[03/17] kylin git commit: KYLIN-2537 fix DeployCoprocessorCLI
KYLIN-2537 fix DeployCoprocessorCLI
Project: http://git-wip-us.apache.org/repos/asf/kylin/repo
Commit: http://git-wip-us.apache.org/repos/asf/kylin/commit/41e383c4
Tree: http://git-wip-us.apache.org/repos/asf/kylin/tree/41e383c4
Diff: http://git-wip-us.apache.org/repos/asf/kylin/diff/41e383c4
Branch: refs/heads/2.0.x-hbase0.98
Commit: 41e383c49073e34952af020ee48e6281174da920
Parents: a997dd6
Author: Li Yang <li...@apache.org>
Authored: Mon Apr 10 18:07:50 2017 +0800
Committer: Li Yang <li...@apache.org>
Committed: Mon Apr 10 18:18:57 2017 +0800
----------------------------------------------------------------------
.../org/apache/kylin/storage/hbase/util/DeployCoprocessorCLI.java | 1 +
1 file changed, 1 insertion(+)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/kylin/blob/41e383c4/storage-hbase/src/main/java/org/apache/kylin/storage/hbase/util/DeployCoprocessorCLI.java
----------------------------------------------------------------------
diff --git a/storage-hbase/src/main/java/org/apache/kylin/storage/hbase/util/DeployCoprocessorCLI.java b/storage-hbase/src/main/java/org/apache/kylin/storage/hbase/util/DeployCoprocessorCLI.java
index 29c738e..d51b71e 100644
--- a/storage-hbase/src/main/java/org/apache/kylin/storage/hbase/util/DeployCoprocessorCLI.java
+++ b/storage-hbase/src/main/java/org/apache/kylin/storage/hbase/util/DeployCoprocessorCLI.java
@@ -420,6 +420,7 @@ public class DeployCoprocessorCLI {
private static Path getCoprocessorHDFSDir(FileSystem fileSystem, KylinConfig config) throws IOException {
String hdfsWorkingDirectory = config.getHdfsWorkingDirectory();
+ hdfsWorkingDirectory = HBaseConnection.makeQualifiedPathInHBaseCluster(hdfsWorkingDirectory);
Path coprocessorDir = new Path(hdfsWorkingDirectory, "coprocessor");
fileSystem.mkdirs(coprocessorDir);
return coprocessorDir;