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/10 10:21:39 UTC
[2/2] 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/ea778d2c
Tree: http://git-wip-us.apache.org/repos/asf/kylin/tree/ea778d2c
Diff: http://git-wip-us.apache.org/repos/asf/kylin/diff/ea778d2c
Branch: refs/heads/yang22
Commit: ea778d2c9748acfe9931bcdd91972cba48630f9c
Parents: 9c82a0d
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:21:24 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/ea778d2c/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 8f69c18..8d20792 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
@@ -382,6 +382,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;