[
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 <lzljs3620...@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)
