[jira] [Created] (STORM-2523) Trident : Cannot join two streams if only one is passed through a persistant aggregator.

["Yannick Ott (JIRA)" <ji...@apache.org>]

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)