Skip to content

Commit 6598737

Browse files
committed
Fix reference leak in ReifyTimestampAndWindowsParDoFnFactory
1 parent e3afe62 commit 6598737

File tree

1 file changed

+7
-2
lines changed

1 file changed

+7
-2
lines changed

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

Lines changed: 7 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -19,6 +19,7 @@
1919

2020
import static org.apache.beam.vendor.guava.v32_1_2_jre.com.google.common.base.Preconditions.checkState;
2121

22+
import org.apache.beam.vendor.guava.v32_1_2_jre.com.google.common.time.Instants;
2223
import com.google.api.services.dataflow.model.SideInputInfo;
2324
import java.util.List;
2425
import java.util.Map;
@@ -87,9 +88,13 @@ public void processElement(Object untypedElem) throws Exception {
8788
public void processTimers() {}
8889

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

9295
@Override
93-
public void abort() throws Exception {}
96+
public void abort() throws Exception {
97+
this.receiver = null;
98+
}
9499
}
95100
}

0 commit comments

Comments
 (0)