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 2020/11/10 14:37:13 UTC

[beam] branch master updated (45ce942 -> d492371)

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

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


    from 45ce942  [BEAM-11188] Add wrappers to Go Xlang examples, and adjust front-end. (#13255)
     add a7a2e01  Refactor checkpointing configuration code
     add 74663e2  [BEAM-9855] Provide an option to configure the Flink state backend
     add d492371  Merge pull request #13116: [BEAM-9855] Provide an option to configure the Flink state backend

No new revisions were added by this update.

Summary of changes:
 runners/flink/flink_runner.gradle                  |  2 +
 .../runners/flink/FlinkExecutionEnvironments.java  | 66 +++++++++++++++++-----
 .../beam/runners/flink/FlinkPipelineOptions.java   | 16 ++++++
 .../flink/FlinkExecutionEnvironmentsTest.java      | 60 ++++++++++++++++++++
 .../runners/flink/FlinkPipelineOptionsTest.java    |  2 +
 .../shortcodes/flink_java_pipeline_options.html    | 10 ++++
 .../shortcodes/flink_python_pipeline_options.html  | 10 ++++
 7 files changed, 152 insertions(+), 14 deletions(-)