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()));
           }
         }
       }