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

Posted to commits@beam.apache.org by ra...@apache.org on 2026/04/14 11:36:19 UTC

(beam) branch master updated (549aa066a90 -> 3f5ce80418b)

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

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


    from 549aa066a90 Add rsync to self-hosted ARC runner Docker image (#38164)
     add 4ba599c3ffb [Drain] Expose drain to dofn processElement and onTimer - add missing implementation for SDF and WindowExpiration processContext
     new 3f5ce80418b Merge pull request #38119 from stankiewicz/fix_drain

The 1 revisions listed above as "new" are entirely new to this
repository and will be described in separate emails.  The revisions
listed as "add" were already present in the repository and have only
been added to this reference.


Summary of changes:
 .../src/main/java/org/apache/beam/fn/harness/FnApiDoFnRunner.java   | 5 +++++
 .../beam/fn/harness/SplittablePairWithRestrictionDoFnRunner.java    | 6 ++++++
 2 files changed, 11 insertions(+)

(beam) 01/01: Merge pull request #38119 from stankiewicz/fix_drain

Posted by ra...@apache.org.

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

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

commit 3f5ce80418be222c4243e2003041048041ae54e0
Merge: 549aa066a90 4ba599c3ffb
Author: Radosław Stankiewicz <ra...@google.com>
AuthorDate: Tue Apr 14 13:36:11 2026 +0200

    Merge pull request #38119 from stankiewicz/fix_drain
    
    [Drain] Expose drain to dofn processElement and onTimer - add missing implementation in ProcessContext

 .../src/main/java/org/apache/beam/fn/harness/FnApiDoFnRunner.java   | 5 +++++
 .../beam/fn/harness/SplittablePairWithRestrictionDoFnRunner.java    | 6 ++++++
 2 files changed, 11 insertions(+)