[jira] [Created] (STORM-873) Flux does not handle "diamond" topologies

["P. Taylor Goetz (JIRA)" <ji...@apache.org>]

P. Taylor Goetz created STORM-873:
-------------------------------------

             Summary: Flux does not handle "diamond" topologies
                 Key: STORM-873
                 URL: https://issues.apache.org/jira/browse/STORM-873
             Project: Apache Storm
          Issue Type: Bug
          Components: Flux
            Reporter: P. Taylor Goetz
            Assignee: P. Taylor Goetz
            Priority: Critical


>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)




--
This message was sent by Atlassian JIRA
(v6.3.4#6332)