You are viewing a plain text version of this content. The canonical link for it is here.
Posted to dev@storm.apache.org by "Jungtaek Lim (JIRA)" <ji...@apache.org> on 2015/11/26 22:41:10 UTC

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

     [ https://issues.apache.org/jira/browse/STORM-873?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ]

Jungtaek Lim updated STORM-873:
-------------------------------
    Fix Version/s: 0.10.0

> 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
>             Fix For: 0.10.0
>
>
> 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)