From 346463903712b0caf6fef91c16a797b782eab7b3 Mon Sep 17 00:00:00 2001
From: Radek Stankiewicz <radoslaws@google.com>
Date: Wed, 6 May 2026 19:23:08 +0200
Subject: [PATCH] Fix WindowedValue.of() invocation.

---
 .../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 b206e66dcf3e..2ce94533d9e2 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 <K, InputT> Iterable<WindowedValue<InputT>> filter(
                     element.getPaneInfo(),
                     element.getRecordId(),
                     element.getRecordOffset(),
-                    element.causedByDrain()));
+                    element.causedByDrain(),
+                    element.getOpenTelemetryContext()));
           }
         }
       }