beam-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From "Aljoscha Krettek (JIRA)" <j...@apache.org>
Subject [jira] [Commented] (BEAM-2930) Flink support for portable side input
Date Fri, 27 Jul 2018 15:31:00 GMT

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

Aljoscha Krettek commented on BEAM-2930:
----------------------------------------

Yes, that sounds like a good approach. I upgraded the Flink Runner to use the new broadcast
state feature when updating to Flink 1.5.0 and there are plans to make this backed by RocksDB
so we will even get support for bigger side inputs once Flink has that support.

> Flink support for portable side input
> -------------------------------------
>
>                 Key: BEAM-2930
>                 URL: https://issues.apache.org/jira/browse/BEAM-2930
>             Project: Beam
>          Issue Type: Sub-task
>          Components: runner-flink
>            Reporter: Henning Rohde
>            Priority: Major
>              Labels: portability
>          Time Spent: 20m
>  Remaining Estimate: 0h
>




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

Mime
View raw message