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 <aljoscha.kret...@gmail.com> Authored: Wed Aug 31 11:05:18 2016 +0200 Committer: Aljoscha Krettek <aljoscha.kret...@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(-) ----------------------------------------------------------------------