Xin Wang created STORM-906:
------------------------------
Summary: Flux "--local --zookeeper" dose not work
Key: STORM-906
URL: https://issues.apache.org/jira/browse/STORM-906
Project: Apache Storm
Issue Type: Bug
Components: Flux
Affects Versions: 0.10.0
Reporter: Xin Wang
Priority: Minor
[description]
-z,--zookeeper <host:port>
When running in local mode, use the ZooKeeper at the specified <host>:<port>
instead of the in-process ZooKeeper.
[/description]
[command]
storm jar topo.jar org.apache.storm.flux.Flux --local --zookeeper
host-A:2181,host-B:2181,host-C:2181 topo.yaml
[/command]
[code]
Flux.java:
...
if(zkStr.contains(":")){
String[] hostPort = zkStr.split(":");
zkHost = hostPort[0];
zkPort = hostPort.length > 1 ?
Long.parseLong(hostPort[1]) : DEFAULT_ZK_PORT;
}
...
[/code]
--
This message was sent by Atlassian JIRA
(v6.3.4#6332)
