Repository: incubator-pirk Updated Branches: refs/heads/master 5cc5e7c24 -> c11b99aa9
PIRK-61: Es-Nodes Option Not Parsed by ResponderCLI, this closes apache/incubator-pirk#85 Project: http://git-wip-us.apache.org/repos/asf/incubator-pirk/repo Commit: http://git-wip-us.apache.org/repos/asf/incubator-pirk/commit/c11b99aa Tree: http://git-wip-us.apache.org/repos/asf/incubator-pirk/tree/c11b99aa Diff: http://git-wip-us.apache.org/repos/asf/incubator-pirk/diff/c11b99aa Branch: refs/heads/master Commit: c11b99aa95c89925377f0cdba73ed9c6e27b82c7 Parents: 5cc5e7c Author: ellisonanne <[email protected]> Authored: Fri Sep 2 15:54:34 2016 -0400 Committer: smarthi <[email protected]> Committed: Fri Sep 2 15:54:34 2016 -0400 ---------------------------------------------------------------------- .../java/org/apache/pirk/responder/wideskies/ResponderCLI.java | 2 +- .../java/org/apache/pirk/responder/wideskies/ResponderProps.java | 2 +- 2 files changed, 2 insertions(+), 2 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/incubator-pirk/blob/c11b99aa/src/main/java/org/apache/pirk/responder/wideskies/ResponderCLI.java ---------------------------------------------------------------------- diff --git a/src/main/java/org/apache/pirk/responder/wideskies/ResponderCLI.java b/src/main/java/org/apache/pirk/responder/wideskies/ResponderCLI.java index 0c031ec..0b306c6 100644 --- a/src/main/java/org/apache/pirk/responder/wideskies/ResponderCLI.java +++ b/src/main/java/org/apache/pirk/responder/wideskies/ResponderCLI.java @@ -228,7 +228,7 @@ public class ResponderCLI // esPort Option optionEsPort = new Option("ep", ResponderProps.ESPORT, true, "required if baseInputFormat = 'elasticsearch' -- ElasticSearch cluster port"); optionEsPort.setRequired(false); - optionEsPort.setArgName(ResponderProps.ESQUERY); + optionEsPort.setArgName(ResponderProps.ESPORT); optionEsPort.setType(String.class); options.addOption(optionEsPort); http://git-wip-us.apache.org/repos/asf/incubator-pirk/blob/c11b99aa/src/main/java/org/apache/pirk/responder/wideskies/ResponderProps.java ---------------------------------------------------------------------- diff --git a/src/main/java/org/apache/pirk/responder/wideskies/ResponderProps.java b/src/main/java/org/apache/pirk/responder/wideskies/ResponderProps.java index f73fdbe..7cba88e 100644 --- a/src/main/java/org/apache/pirk/responder/wideskies/ResponderProps.java +++ b/src/main/java/org/apache/pirk/responder/wideskies/ResponderProps.java @@ -112,7 +112,7 @@ public class ResponderProps STORMSPLITPARTITIONS, STORMSALTCOLUMNS, STORMNUMROWDIVS}; static final List<String> PROPSLIST = Arrays.asList((String[]) ArrayUtils.addAll(new String[] {PLATFORM, QUERYINPUT, DATAINPUTFORMAT, INPUTDATA, BASEQUERY, - ESRESOURCE, ESQUERY, OUTPUTFILE, BASEINPUTFORMAT, STOPLISTFILE, NUMREDUCETASKS, USELOCALCACHE, LIMITHITSPERSELECTOR, MAXHITSPERSELECTOR, MAPMEMORY, + ESRESOURCE, ESQUERY, ESNODES, OUTPUTFILE, BASEINPUTFORMAT, STOPLISTFILE, NUMREDUCETASKS, USELOCALCACHE, LIMITHITSPERSELECTOR, MAXHITSPERSELECTOR, MAPMEMORY, REDUCEMEMORY, MAPJAVAOPTS, REDUCEJAVAOPTS, QUERYSCHEMAS, DATASCHEMAS, NUMEXPLOOKUPPARTS, USEHDFSLOOKUPTABLE, NUMDATAPARTITIONS, NUMCOLMULTPARTITIONS, USEMODEXPJOIN, COLMULTREDUCEBYKEY, ALLOWEMBEDDEDQUERYSCHEMAS, BATCHSECONDS, WINDOWLENGTH, USEQUEUESTREAM, MAXBATCHES, STOPGRACEFULLY}, STORMPROPS));
