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 f93a332a20857f425fa1c1b69d2423f3c2e7880d
Merge: 302b247 0e44feb
Author: Aljoscha Krettek <aljoscha.kret...@gmail.com>
AuthorDate: Tue Mar 27 06:49:21 2018 +0200
Merge pull request #4895: [BEAM-2393] Make BoundedSource fault-tolerant in
FlinkRunner Streaming mode
.../UnboundedReadFromBoundedSource.java | 5 +-
.../flink/FlinkStreamingTransformTranslators.java | 138 ++++++++++-
.../streaming/io/BoundedSourceWrapper.java | 259 ---------------------
.../streaming/io/UnboundedSourceWrapper.java | 67 +++---
.../flink/streaming/BoundedSourceRestoreTest.java | 236 +++++++++++++++++++
5 files changed, 404 insertions(+), 301 deletions(-)
--
To stop receiving notification emails like this one, please contact
aljos...@apache.org.
