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/05/18 13:33:50 UTC

[beam] branch master updated (d773f8c -> 7c80ecb)

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 d773f8c  [BEAM-2530] Implement Zeta SQL precommit compile tests and run on java 11 (#11692)
     add 401f213  [BEAM-6733] Add pipeline option to flush bundle data before checkpointing
     add 7c80ecb  Merge pull request #11678: [BEAM-6733] Add pipeline option to flush bundle data before checkpointing

No new revisions were added by this update.

Summary of changes:
 .../beam/runners/flink/FlinkPipelineOptions.java   | 11 ++++++-
 .../wrappers/streaming/DoFnOperator.java           | 28 +++++++++++++---
 .../runners/flink/FlinkPipelineOptionsTest.java    |  1 +
 .../website/PipelineOptionsTableGenerator.java     |  4 +--
 .../shortcodes/flink_java_pipeline_options.html    | 20 ++++++++----
 .../shortcodes/flink_python_pipeline_options.html  | 38 +++++++++++++---------
 6 files changed, 72 insertions(+), 30 deletions(-)