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

Posted to commits@beam.apache.org by mx...@apache.org on 2018/12/03 10:08:57 UTC

[beam] 01/01: Merge pull request #7169: [BEAM-5396] Savepoint restore option in Flink runner

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

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

commit 236d0dd89c210e235ef45be9663ec77267d7b451
Merge: b469880 f2d1581
Author: Maximilian Michels <mx...@apache.org>
AuthorDate: Mon Dec 3 11:08:49 2018 +0100

    Merge pull request #7169: [BEAM-5396] Savepoint restore option in Flink runner

 .../runners/flink/FlinkExecutionEnvironments.java  | 105 ++++++++++++++++++++-
 .../beam/runners/flink/FlinkPipelineOptions.java   |  14 +++
 .../flink/FlinkExecutionEnvironmentsTest.java      |  22 +++++
 .../beam/runners/flink/PipelineOptionsTest.java    |   2 +
 4 files changed, 141 insertions(+), 2 deletions(-)