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-cdh5.7 Commit: ea778d2c9748acfe9931bcdd91972cba48630f9c Parents: 9c82a0d Author: Li Yang <liy...@apache.org> Authored: Mon Apr 10 18:07:50 2017 +0800 Committer: Li Yang <liy...@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;