This is an automated email from the ASF dual-hosted git repository. stankiewicz pushed a commit to branch master in repository https://gitbox.apache.org/repos/asf/beam.git
commit da391d0e3d7edc18fa8751679a7cc7328cd1ef06 Merge: d6b98ba9019 79f7db946b1 Author: Radosław Stankiewicz <[email protected]> AuthorDate: Wed May 6 16:26:32 2026 +0200 Merge pull request #38230 from stankiewicz/drain_combiner [Drain] Support extensible element metadata propagation in ReduceFnRunner runners/core-java/build.gradle | 1 + .../apache/beam/runners/core/CombinedMetadata.java | 87 ++++++++++++++++++++ .../runners/core/CombinedMetadataCombiner.java | 78 ++++++++++++++++++ .../runners/core/LateDataDroppingDoFnRunner.java | 8 +- .../apache/beam/runners/core/MetadataCombiner.java | 25 ++++++ .../apache/beam/runners/core/ReduceFnRunner.java | 55 ++++++++++--- .../beam/runners/core/CombinedMetadataTest.java | 70 ++++++++++++++++ .../apache/beam/runners/core/ReduceFnTester.java | 5 +- .../wrappers/streaming/WindowDoFnOperatorTest.java | 10 +++ .../beam/runners/dataflow/worker/WindmillSink.java | 8 +- .../worker/StreamingDataflowWorkerTest.java | 37 +++++++-- .../org/apache/beam/sdk/values/WindowedValues.java | 4 + .../sdk/transforms/MetadataPropagationTest.java | 95 ++++++++++++++++++++-- 13 files changed, 453 insertions(+), 30 deletions(-)
