You are viewing a plain text version of this content. The canonical link for it is here.
Posted to dev@storm.apache.org by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2015/06/18 06:03:10 UTC
[jira] [Commented] (STORM-873) Flux does not handle "diamond"
topologies
[ https://issues.apache.org/jira/browse/STORM-873?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14591203#comment-14591203 ]
ASF GitHub Bot commented on STORM-873:
--------------------------------------
GitHub user ptgoetz opened a pull request:
https://github.com/apache/storm/pull/596
STORM-873: Flux does not handle diamond topologies
JIRA: https://issues.apache.org/jira/browse/STORM-873
You can merge this pull request into a Git repository by running:
$ git pull https://github.com/ptgoetz/storm STORM-873
Alternatively you can review and apply these changes as the patch at:
https://github.com/apache/storm/pull/596.patch
To close this pull request, make a commit to your master/trunk branch
with (at least) the following in the commit message:
This closes #596
----
commit f95196031144bac23453ccce813667e8ec652a63
Author: P. Taylor Goetz <pt...@gmail.com>
Date: 2015-06-18T03:59:58Z
STORM-873: Flux does not handle diamond topologies
----
> 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)