Skip to content

Commit b6556b4

Browse files
authored
Fix reference leak in ReifyTimestampAndWindowsParDoFnFactory (#36968)
1 parent e3afe62 commit b6556b4

File tree

1 file changed

+6
-2
lines changed

1 file changed

+6
-2
lines changed

runners/google-cloud-dataflow-java/worker/src/main/java/org/apache/beam/runners/dataflow/worker/ReifyTimestampAndWindowsParDoFnFactory.java

Lines changed: 6 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -87,9 +87,13 @@ public void processElement(Object untypedElem) throws Exception {
8787
public void processTimers() {}
8888

8989
@Override
90-
public void finishBundle() throws Exception {}
90+
public void finishBundle() throws Exception {
91+
this.receiver = null;
92+
}
9193

9294
@Override
93-
public void abort() throws Exception {}
95+
public void abort() throws Exception {
96+
this.receiver = null;
97+
}
9498
}
9599
}

0 commit comments

Comments
 (0)