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

Posted to commits@beam.apache.org by ja...@apache.org on 2023/10/24 06:29:59 UTC

[beam] 01/01: Merge pull request #29102: [flink] Flush buffer during drain operation for requiresStableInput operator

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

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

commit bf5ded44e6ee7e9e752f44379df43a3aa453fc7e
Merge: 3f05945888e 1a27d2cee0c
Author: Jan Lukavský <je...@seznam.cz>
AuthorDate: Tue Oct 24 08:29:50 2023 +0200

    Merge pull request #29102: [flink] Flush buffer during drain operation for requiresStableInput operator

 .../beam/runners/flink/FlinkPipelineOptions.java   |  8 ++
 .../wrappers/streaming/DoFnOperator.java           | 14 ++++
 .../wrappers/streaming/DoFnOperatorTest.java       | 92 ++++++++++++++++++++++
 .../shortcodes/flink_java_pipeline_options.html    |  5 ++
 .../shortcodes/flink_python_pipeline_options.html  |  5 ++
 5 files changed, 124 insertions(+)