Ted Yu created BEAM-3915: ---------------------------- Summary: Unclosed reader in JavaReadViaImpulse#ReadFromBoundedSourceFn Key: BEAM-3915 URL: https://issues.apache.org/jira/browse/BEAM-3915 Project: Beam Issue Type: Bug Components: runner-core Reporter: Ted Yu Assignee: Kenneth Knowles
{code} static class ReadFromBoundedSourceFn<T> extends DoFn<BoundedSource<T>, T> { @ProcessElement public void readSoruce(ProcessContext ctxt) throws IOException { BoundedSource.BoundedReader<T> reader = ctxt.element().createReader(ctxt.getPipelineOptions()); {code} The reader should be closed upon return from the method. -- This message was sent by Atlassian JIRA (v7.6.3#76005)