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 2019/02/22 10:20:08 UTC
[kylin] branch 2.6.x updated: KYLIN-3822 fix the param parse error
in DeployCoprocessorCLI (#476)
This is an automated email from the ASF dual-hosted git repository.
shaofengshi pushed a commit to branch 2.6.x
in repository https://gitbox.apache.org/repos/asf/kylin.git
The following commit(s) were added to refs/heads/2.6.x by this push:
new b3aa5f6 KYLIN-3822 fix the param parse error in DeployCoprocessorCLI (#476)
b3aa5f6 is described below
commit b3aa5f6daac9828a82f00b442c8ae03150520807
Author: 470024581 <47...@qq.com>
AuthorDate: Fri Feb 22 18:18:21 2019 +0800
KYLIN-3822 fix the param parse error in DeployCoprocessorCLI (#476)
KYLIN-3822 fix the param parse error in DeployCoprocessorCLI
---
.../apache/kylin/storage/hbase/util/DeployCoprocessorCLI.java | 9 +++++----
1 file changed, 5 insertions(+), 4 deletions(-)
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 7781ca0..0af00ef 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
@@ -98,19 +98,20 @@ public class DeployCoprocessorCLI {
hbaseAdmin = conn.getAdmin();
String localCoprocessorJar;
int curIdx = 0;
- if ("default".equals(args[curIdx++])) {
+ if ("default".equals(args[curIdx])) {
localCoprocessorJar = kylinConfig.getCoprocessorLocalJar();
} else {
localCoprocessorJar = new File(args[curIdx]).getAbsolutePath();
}
-
+ curIdx++;
logger.info("Identify coprocessor jar " + localCoprocessorJar);
try {
- MAX_THREADS = Integer.parseInt(args[curIdx++]);
+ MAX_THREADS = Integer.parseInt(args[curIdx]);
} catch (Exception e) {
- curIdx--;
+
}
+ curIdx++;
logger.info("Use at most {} threads to do upgrade", MAX_THREADS);
List<String> tableNames = getHTableNames(kylinConfig);