You are viewing a plain text version of this content. The canonical link for it is here.

Posted to commits@beam.apache.org by th...@apache.org on 2018/10/10 05:34:21 UTC

[beam] 01/01: Merge pull request #6617: [BEAM-5687] Fix checkpointing of FlinkRunner for portable pipelines

This is an automated email from the ASF dual-hosted git repository.

thw pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/beam.git

commit 88c68457306b2e3a369cdddc64b594069eda4971
Merge: d32364c 0ebf2db
Author: Thomas Weise <tw...@users.noreply.github.com>
AuthorDate: Tue Oct 9 22:34:13 2018 -0700

    Merge pull request #6617: [BEAM-5687] Fix checkpointing of FlinkRunner for portable pipelines

 .../runners/flink/FlinkExecutionEnvironments.java  |  4 ++
 .../beam/runners/flink/FlinkPipelineOptions.java   | 11 ++--
 .../FlinkStreamingPortablePipelineTranslator.java  | 19 +++---
 .../functions/ImpulseSourceFunction.java           | 75 ++++++++++++++++++++++
 4 files changed, 96 insertions(+), 13 deletions(-)