pirk-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From smar...@apache.org
Subject incubator-pirk git commit: PIRK-61: Es-Nodes Option Not Parsed by ResponderCLI, this closes apache/incubator-pirk#85
Date Fri, 02 Sep 2016 19:55:19 GMT
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 <eawilliams@apache.org>
Authored: Fri Sep 2 15:54:34 2016 -0400
Committer: smarthi <smarthi@apache.org>
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));
 


Mime
View raw message