[
https://issues.apache.org/jira/browse/FLINK-8479?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16341638#comment-16341638
]
ASF GitHub Bot commented on FLINK-8479:
---------------------------------------
Github user bowenli86 commented on the issue:
https://github.com/apache/flink/pull/5342
Very interesting! two things:
1. can you make the google doc publicly viewable? I cannot access it right
now
2. how does it handle event time window joins of two streams, where data in
one stream always quite late than the other? For example, we are joining stream
A and B on a 10 min event-time tumbling window from 12:00 -12:10, 12:10 -
12:20.... data in stream B always arrive 30 mins later than the data in stream
A. How does the operators handle that? Does it cache A's data until B's data
arrives, do the join, and remove A's data from cache? (I haven't read the
code in detail, just try to get a general idea of the overall design)
> Implement time-bounded inner join of streams as a TwoInputStreamOperator
> ------------------------------------------------------------------------
>
> Key: FLINK-8479
> URL: https://issues.apache.org/jira/browse/FLINK-8479
> Project: Flink
> Issue Type: Sub-task
> Reporter: Florian Schmidt
> Priority: Major
>
--
This message was sent by Atlassian JIRA
(v7.6.3#76005)
