From a04251ab4a6183dc776cd41429605162b80373b3 Mon Sep 17 00:00:00 2001
From: Yi Hu <yathu@google.com>
Date: Tue, 2 Dec 2025 16:47:09 -0500
Subject: [PATCH] Fix reference leak in ReifyTimestampAndWindowsParDoFnFactory

---
 .../worker/ReifyTimestampAndWindowsParDoFnFactory.java    | 8 ++++++--
 1 file changed, 6 insertions(+), 2 deletions(-)

diff --git a/runners/google-cloud-dataflow-java/worker/src/main/java/org/apache/beam/runners/dataflow/worker/ReifyTimestampAndWindowsParDoFnFactory.java b/runners/google-cloud-dataflow-java/worker/src/main/java/org/apache/beam/runners/dataflow/worker/ReifyTimestampAndWindowsParDoFnFactory.java
index 248ed34e8c40..746c09404f6e 100644
--- a/runners/google-cloud-dataflow-java/worker/src/main/java/org/apache/beam/runners/dataflow/worker/ReifyTimestampAndWindowsParDoFnFactory.java
+++ b/runners/google-cloud-dataflow-java/worker/src/main/java/org/apache/beam/runners/dataflow/worker/ReifyTimestampAndWindowsParDoFnFactory.java
@@ -87,9 +87,13 @@ public void processElement(Object untypedElem) throws Exception {
     public void processTimers() {}
 
     @Override
-    public void finishBundle() throws Exception {}
+    public void finishBundle() throws Exception {
+      this.receiver = null;
+    }
 
     @Override
-    public void abort() throws Exception {}
+    public void abort() throws Exception {
+      this.receiver = null;
+    }
   }
 }