From 81a838cd15c34853517de9d204f969e67a678c14 Mon Sep 17 00:00:00 2001
From: Radek Stankiewicz <radoslaws@google.com>
Date: Thu, 27 Nov 2025 11:02:47 +0100
Subject: [PATCH] propagate offset and record  in output builder

---
 .../java/org/apache/beam/sdk/values/WindowedValues.java   | 8 +++++++-
 1 file changed, 7 insertions(+), 1 deletion(-)

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