You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@beam.apache.org by al...@apache.org on 2016/08/31 09:06:21 UTC
[2/2] incubator-beam git commit: Merge branch 'flink-fixes'
Merge branch 'flink-fixes'
This closes #883
Project: http://git-wip-us.apache.org/repos/asf/incubator-beam/repo
Commit: http://git-wip-us.apache.org/repos/asf/incubator-beam/commit/1dc1f25b
Tree: http://git-wip-us.apache.org/repos/asf/incubator-beam/tree/1dc1f25b
Diff: http://git-wip-us.apache.org/repos/asf/incubator-beam/diff/1dc1f25b
Branch: refs/heads/master
Commit: 1dc1f25b64eed7679e5d30309d5634052d187814
Parents: 33d747e cae9638
Author: Aljoscha Krettek <al...@gmail.com>
Authored: Wed Aug 31 11:05:18 2016 +0200
Committer: Aljoscha Krettek <al...@gmail.com>
Committed: Wed Aug 31 11:05:18 2016 +0200
----------------------------------------------------------------------
.../beam/runners/core/SideInputHandler.java | 6 +-
.../apache/beam/runners/flink/FlinkRunner.java | 86 ++++++++++++++++++--
.../wrappers/streaming/DoFnOperator.java | 13 ++-
.../wrappers/streaming/WindowDoFnOperator.java | 2 -
4 files changed, 89 insertions(+), 18 deletions(-)
----------------------------------------------------------------------