Ted Yu created BEAM-2608: ---------------------------- Summary: Unclosed BoundedReader in TextIO#ReadTextFn#process() Key: BEAM-2608 URL: https://issues.apache.org/jira/browse/BEAM-2608 Project: Beam Issue Type: Bug Components: sdk-java-core Reporter: Ted Yu Assignee: Davor Bonaci Priority: Minor
{code} BoundedSource.BoundedReader<String> reader = source .createForSubrangeOfFile(metadata, range.getFrom(), range.getTo()) .createReader(c.getPipelineOptions()); {code} The reader should be closed upon return. -- This message was sent by Atlassian JIRA (v6.4.14#64029)