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

Posted to commits@beam.apache.org by gi...@apache.org on 2023/05/28 05:01:36 UTC

[beam] branch nightly-refs/heads/master updated (fcd69f02ba1 -> 68d991aef26)

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

github-bot pushed a change to branch nightly-refs/heads/master
in repository https://gitbox.apache.org/repos/asf/beam.git


    from fcd69f02ba1 Switch Flink load test with lcg synthetic data (#26893)
     add 94078e54224 Publish pipeline options to flink web ui (#26009)
     add 68d991aef26 [Flink][KafkaIO] Finalize checkpoints during stop/drain scenario (#26883)

No new revisions were added by this update.

Summary of changes:
 .../runners/flink/FlinkExecutionEnvironments.java  | 63 ++++++++++++++++++++++
 .../streaming/io/UnboundedSourceWrapper.java       | 59 ++++++++++----------
 .../flink/FlinkExecutionEnvironmentsTest.java      | 58 ++++++++++++++++++++
 .../streaming/io/UnboundedSourceWrapperTest.java   |  6 +++
 .../beam/sdk/io/kafka/KafkaUnboundedReader.java    | 33 +++++++-----
 .../shortcodes/flink_java_pipeline_options.html    |  2 -
 .../shortcodes/flink_python_pipeline_options.html  |  2 -
 7 files changed, 176 insertions(+), 47 deletions(-)