Skip to content

Commit ead63ad

Browse files
authored
Merge pull request #36926: Offset deduplication - Propagate offset and record in output builder
2 parents cbc31be + 81a838c commit ead63ad

File tree

1 file changed

+7
-1
lines changed

1 file changed

+7
-1
lines changed

sdks/java/core/src/main/java/org/apache/beam/sdk/values/WindowedValues.java

Lines changed: 7 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -231,7 +231,13 @@ public void output() {
231231

232232
public WindowedValue<T> build() {
233233
return WindowedValues.of(
234-
getValue(), getTimestamp(), getWindows(), getPaneInfo(), null, null, causedByDrain());
234+
getValue(),
235+
getTimestamp(),
236+
getWindows(),
237+
getPaneInfo(),
238+
getRecordId(),
239+
getRecordOffset(),
240+
causedByDrain());
235241
}
236242

237243
@Override

0 commit comments

Comments
 (0)