Details
-
Bug
-
Status: Resolved
-
P3
-
Resolution: Duplicate
-
None
-
None
Description
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());
The reader should be closed upon return from the method.
Attachments
Issue Links
- is related to
-
BEAM-3934 BoundedReader should be closed in JavaReadViaImpulse#ReadFromBoundedSourceFn
- Resolved