[STORM-873] Flux does not handle "diamond" topologies

• Type: Bug
• Status: Resolved
• Priority: Critical
• Resolution: Fixed
• Fix Version/s: 0.10.0
• Component/s: Flux
• Assignee: P. Taylor Goetz
• Reporter: P. Taylor Goetz
• Created: 18/Jun/15 03:52
• Updated: 26/Nov/15 21:40
• Resolved: 27/Jun/15 16:33

Description

From email report on user@:

It builds something like below (imagine the arrow from A-> B, A-> C,
B->D, and C->D)
---------------------------------------------------------
Bolt_B
Spout -> Bolt_A -> Bolt_D
Bolt_C
---------------------------------------------------------

I get an error below in FLUX.

Exception in thread "main" java.lang.IllegalArgumentException: Bolt
has already been declared for id bolt_D
at backtype.storm.topology.TopologyBuilder.validateUnusedId(TopologyBuilder.java:212)
at backtype.storm.topology.TopologyBuilder.setBolt(TopologyBuilder.java:139)
at org.apache.storm.flux.FluxBuilder.buildStreamDefinitions(FluxBuilder.java:158)
at org.apache.storm.flux.FluxBuilder.buildTopology(FluxBuilder.java:94)
at org.apache.storm.flux.Flux.runCli(Flux.java:153)
at org.apache.storm.flux.Flux.main(Flux.java:98)