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 2018/03/27 04:50:29 UTC

[beam] 03/03: Merge pull request #4895: [BEAM-2393] Make BoundedSource fault-tolerant in FlinkRunner Streaming mode

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 <al...@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
aljoscha@apache.org.