Details
Description
Currently, there is no way to call `RecordReaderImpl.close` if `RecordReader.rows` fails at creating `RecordReaderImpl`. This issue aims to try to invoke `close` in the constructor in case of Exceptions.
@Override public RecordReader rows(Options options) throws IOException { LOG.info("Reading ORC rows from " + path + " with " + options); return new RecordReaderImpl(this, options); }
Attachments
Issue Links
- is related to
-
SPARK-23390 Flaky test: FileBasedDataSourceSuite
- Resolved
- relates to
-
SPARK-25688 Potential resource leak in ORC
- Resolved
- links to
(1 links to)