This is an automated email from the ASF dual-hosted git repository.
aljoscha pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/beam.git
commit 0259636661998b8aabd3bf20eff8d519bcb9fb47
Merge: 51b793a 6148a6d
Author: Aljoscha Krettek <aljoscha.kret...@gmail.com>
AuthorDate: Fri Feb 23 11:59:36 2018 +0100
Merge pull request #4639: [BEAM-2140] Fix SplittableDoFn ValidatesRunner
tests in Flink Streaming Runner
.../org/apache/beam/runners/core/DoFnRunners.java | 4 +-
.../apache/beam/runners/core/ProcessFnRunner.java | 2 +-
runners/flink/build.gradle | 24 ++--
runners/flink/pom.xml | 1 -
.../beam/runners/flink/FlinkPipelineOptions.java | 12 ++
.../flink/FlinkStreamingTransformTranslators.java | 35 +++++-
.../apache/beam/runners/flink/TestFlinkRunner.java | 1 +
.../wrappers/streaming/DoFnOperator.java | 127 +++++++++++++--------
.../wrappers/streaming/SplittableDoFnOperator.java | 16 +++
.../wrappers/streaming/WindowDoFnOperator.java | 18 +++
.../streaming/io/BoundedSourceWrapper.java | 28 +++++
.../streaming/io/UnboundedSourceWrapper.java | 56 ++++-----
12 files changed, 234 insertions(+), 90 deletions(-)
--
To stop receiving notification emails like this one, please contact
aljos...@apache.org.
