(beam) branch master updated: Fix WindowedValue.of() invocation. (#38380)

[radek]

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


The following commit(s) were added to refs/heads/master by this push:
     new 6fc8fdebb23 Fix WindowedValue.of() invocation. (#38380)
6fc8fdebb23 is described below

commit 6fc8fdebb2349d9efbb1b562407e08d787d01d8f
Author: Radosław Stankiewicz <radosl...@google.com>
AuthorDate: Wed May 6 19:38:16 2026 +0200

    Fix WindowedValue.of() invocation. (#38380)
---
 .../java/org/apache/beam/runners/core/LateDataDroppingDoFnRunner.java  | 3 ++-
 1 file changed, 2 insertions(+), 1 deletion(-)

diff --git 
a/runners/core-java/src/main/java/org/apache/beam/runners/core/LateDataDroppingDoFnRunner.java
 
b/runners/core-java/src/main/java/org/apache/beam/runners/core/LateDataDroppingDoFnRunner.java
index b206e66dcf3..2ce94533d9e 100644
--- 
a/runners/core-java/src/main/java/org/apache/beam/runners/core/LateDataDroppingDoFnRunner.java
+++ 
b/runners/core-java/src/main/java/org/apache/beam/runners/core/LateDataDroppingDoFnRunner.java
@@ -151,7 +151,8 @@ public class LateDataDroppingDoFnRunner<K, InputT, OutputT, 
W extends BoundedWin
                     element.getPaneInfo(),
                     element.getRecordId(),
                     element.getRecordOffset(),
-                    element.causedByDrain()));
+                    element.causedByDrain(),
+                    element.getOpenTelemetryContext()));
           }
         }
       }