[BEAM-10997] Make sure SDF unbounded wrapper close reader properly

• Type: Bug
• Status: Resolved
• Priority: P2
• Resolution: Fixed
• Affects Version/s: 2.24.0
• Fix Version/s: 2.25.0
• Component/s: sdk-java-core
• Labels: Done
• Assignee: Boyuan Zhang
• Reporter: Boyuan Zhang
• Created: 01/Oct/20 04:58
• Updated: 15/May/21 20:55
• Resolved: 15/May/21 20:55

Description

At least it seems like when checkpoint happens, we set the currentReader to empty source reader directly without closing it properly:
https://github.com/apache/beam/blob/master/sdks/java/core/src/main/java/org/apache/beam/sdk/io/Read.java#L869-L870

Issue Links

• links to: GitHub Pull Request #13040
• links to: https://github.com/apache/beam/pull/13041