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

Jungtaek Lim resolved STORM-2761.
---------------------------------
    Resolution: Not A Problem

> JoinBolt.java 's paradigm is new model of stream join?
> ------------------------------------------------------
>
>                 Key: STORM-2761
>                 URL: https://issues.apache.org/jira/browse/STORM-2761
>             Project: Apache Storm
>          Issue Type: Question
>          Components: storm-client
>            Reporter: Fei Pan
>            Priority: Critical
>
> Hi, I am a researcher from University of Toronto and I am studying 
> acceleration on stream processing platform. I have a question about the model 
> of window-based stream join used in the JoinBolt.java. From my understanding, 
> when a new tuple arrived, we join this new tuple with all the tuples in the 
> window of the opposite stream. However, in the JoinBolt.java, not only the 
> new tuple, but the tuples in the entire local window will join with the 
> window of the opposite stream. This actually produces a lot of duplicated 
> results, since most of the old tuples in the local window have joined before. 
> I don't know if this is a new paradigm or the storm's team misunderstood the 
> model of stream join. Can someone help me to clarify this question?



--
This message was sent by Atlassian JIRA
(v7.6.3#76005)

Reply via email to