beam-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From aljos...@apache.org
Subject [2/2] incubator-beam git commit: Merge branch 'flink-fixes'
Date Wed, 31 Aug 2016 09:06:21 GMT
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.krettek@gmail.com>
Authored: Wed Aug 31 11:05:18 2016 +0200
Committer: Aljoscha Krettek <aljoscha.krettek@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(-)
----------------------------------------------------------------------



Mime
View raw message