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(-)