[STORM-906] Flux "--local --zookeeper" dose not work

• Type: Bug
• Status: Closed
• Priority: Minor
• Resolution: Not A Problem
• Affects Version/s: 0.10.0
• Component/s: Flux
• Assignee: Unassigned
• Reporter: Xin Wang
• Created: 24/Jun/15 06:45
• Updated: 21/Jul/15 04:23
• Resolved: 21/Jul/15 04:23

Description

[description]
z,-zookeeper <host:port>
When running in local mode, use the ZooKeeper at the specified <host>:<port> instead of the in-process ZooKeeper.
But when using zookeeper string like 'host-A:2181,host-B:2181,host-C:2181', Flux dose not work well.

[command]

storm jar topo.jar org.apache.storm.flux.Flux --local --zookeeper host-A:2181,host-B:2181,host-C:2181 topo.yaml

[code]
Flux.java:

...
if(zkStr.contains(":")){
                        String[] hostPort = zkStr.split(":");
                        zkHost = hostPort[0];
                        zkPort = hostPort.length > 1 ? Long.parseLong(hostPort[1]) : DEFAULT_ZK_PORT;

 }
...