(beam) branch master updated: Fix reference leak in ReifyTimestampAndWindowsParDoFnFactory (#36968)

[yhu]

This is an automated email from the ASF dual-hosted git repository.

yhu pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/beam.git


The following commit(s) were added to refs/heads/master by this push:
     new b6556b4777b Fix reference leak in 
ReifyTimestampAndWindowsParDoFnFactory (#36968)
b6556b4777b is described below

commit b6556b4777be409b6fac88ed09b568618bfe7b00
Author: Yi Hu <ya...@google.com>
AuthorDate: Tue Dec 2 22:36:11 2025 -0500

    Fix reference leak in ReifyTimestampAndWindowsParDoFnFactory (#36968)
---
 .../dataflow/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 248ed34e8c4..746c09404f6 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 @@ class ReifyTimestampAndWindowsParDoFnFactory implements 
ParDoFnFactory {
     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;
+    }
   }
 }