diff --git a/sdks/java/core/src/main/java/org/apache/beam/sdk/values/WindowedValues.java b/sdks/java/core/src/main/java/org/apache/beam/sdk/values/WindowedValues.java
index 518b9a62647e..b194207000ed 100644
--- a/sdks/java/core/src/main/java/org/apache/beam/sdk/values/WindowedValues.java
+++ b/sdks/java/core/src/main/java/org/apache/beam/sdk/values/WindowedValues.java
@@ -231,7 +231,13 @@ public void output() {
 
     public WindowedValue<T> build() {
       return WindowedValues.of(
-          getValue(), getTimestamp(), getWindows(), getPaneInfo(), null, null, causedByDrain());
+          getValue(),
+          getTimestamp(),
+          getWindows(),
+          getPaneInfo(),
+          getRecordId(),
+          getRecordOffset(),
+          causedByDrain());
     }
 
     @Override