[BEAM-2608] Unclosed BoundedReader in TextIO#ReadTextFn#process()

• Type: Bug
• Status: Resolved
• Priority: P3
• Resolution: Fixed
• Fix Version/s: 2.2.0
• Component/s: sdk-java-core
• Labels: Done
• Assignee: Eugene Kirpichov
• Reporter: Ted Yu
• Created: 12/Jul/17 19:16
• Updated: 06/Oct/20 21:59
• Resolved: 16/Jul/17 00:39

Description

        BoundedSource.BoundedReader<String> reader =
            source
                .createForSubrangeOfFile(metadata, range.getFrom(), range.getTo())
                .createReader(c.getPipelineOptions());

The reader should be closed upon return.

Issue Links

• links to: GitHub Pull Request #3567