Yannick Ott created STORM-2523:
----------------------------------
Summary: Trident : Cannot join two streams if only one is passed
through a persistant aggregator.
Key: STORM-2523
URL: https://issues.apache.org/jira/browse/STORM-2523
Project: Apache Storm
Issue Type: Bug
Components: trident
Affects Versions: 1.0.1
Reporter: Yannick Ott
Attachments: AggregateAndJoin.java
When i define a topology such :
Spout1 -> persistantAggregator -> Stream -> join
Spout2 -> Join (the same one)
Join never produces data.
To produce data i need to add a persistantAggregator in other stream.
This persistantAggregator aggregate nothing and just repeat input tuple.
I join a java class testing each configuration
thx
--
This message was sent by Atlassian JIRA
(v6.3.15#6346)
