Skip to content

Commit 6fc8fde

Browse files
authored
Fix WindowedValue.of() invocation. (#38380)
1 parent 7235088 commit 6fc8fde

1 file changed

Lines changed: 2 additions & 1 deletion

File tree

runners/core-java/src/main/java/org/apache/beam/runners/core/LateDataDroppingDoFnRunner.java

Lines changed: 2 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -151,7 +151,8 @@ public <K, InputT> Iterable<WindowedValue<InputT>> filter(
151151
element.getPaneInfo(),
152152
element.getRecordId(),
153153
element.getRecordOffset(),
154-
element.causedByDrain()));
154+
element.causedByDrain(),
155+
element.getOpenTelemetryContext()));
155156
}
156157
}
157158
}

0 commit comments

Comments
 (0)