flink-issues mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From "Stephan Ewen (JIRA)" <j...@apache.org>
Subject [jira] [Commented] (FLINK-8528) Bucket MapState of TimeBoundedStreamJoinOperator for improved performance
Date Fri, 06 Jul 2018 08:20:00 GMT

    [ https://issues.apache.org/jira/browse/FLINK-8528?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16534561#comment-16534561
] 

Stephan Ewen commented on FLINK-8528:
-------------------------------------

Not sure if this is actually beneficial, performance wise.
One would need to append rows across timestamps to a list that is expensive to modify and
would need to have an additional filter within that list.

My feeling is that having a SortedMapState is the way to go and will have the benefits that
this approach is looking at, without the downsides of this approach.

> Bucket MapState of TimeBoundedStreamJoinOperator for improved performance
> -------------------------------------------------------------------------
>
>                 Key: FLINK-8528
>                 URL: https://issues.apache.org/jira/browse/FLINK-8528
>             Project: Flink
>          Issue Type: Sub-task
>            Reporter: Florian Schmidt
>            Priority: Major
>




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

Mime
View raw message