beam-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From "ASF GitHub Bot (JIRA)" <j...@apache.org>
Subject [jira] [Commented] (BEAM-1393) Update Flink Runner to Flink 1.2.0
Date Wed, 15 Feb 2017 09:27:41 GMT

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

ASF GitHub Bot commented on BEAM-1393:
--------------------------------------

GitHub user aljoscha opened a pull request:

    https://github.com/apache/beam/pull/2012

    [BEAM-1393/1394/1445] Update to Flink 1.2.0 and fix resulting problems

    This is a copy of #1960. I'm hoping to be able to figure out what's causing the problems
in the Maven verify hook.

You can merge this pull request into a Git repository by running:

    $ git pull https://github.com/aljoscha/beam finish-pr-1969-flink12

Alternatively you can review and apply these changes as the patch at:

    https://github.com/apache/beam/pull/2012.patch

To close this pull request, make a commit to your master/trunk branch
with (at least) the following in the commit message:

    This closes #2012
    
----
commit a4e182a731b8e09b6b9017c1f316991883492884
Author: JingsongLi <lzljs3620320@aliyun.com>
Date:   2017-02-07T08:11:12Z

    [BEAM-1393/1394/1445] Update to Flink 1.2.0 and fix resulting problems
    
    We now use the Flink InternalTimerService for all our timer needs and we
    use Flink Broadcast state to store side inputs.
    
    Changing those was both necessary and easier to to in one commit while
    updating to Flink 1.2.

----


> Update Flink Runner to Flink 1.2.0
> ----------------------------------
>
>                 Key: BEAM-1393
>                 URL: https://issues.apache.org/jira/browse/BEAM-1393
>             Project: Beam
>          Issue Type: Improvement
>          Components: runner-flink
>            Reporter: Aljoscha Krettek
>            Assignee: Jingsong Lee
>
> When we update to 1.2.0 we can use the new internal Timer API that is available to Flink
operators: {{InternalTimerService}} and also use broadcast state to store side-input data.



--
This message was sent by Atlassian JIRA
(v6.3.15#6346)

Mime
View raw message