diff --git a/ql/src/java/org/apache/hadoop/hive/ql/io/avro/AvroGenericRecordReader.java b/ql/src/java/org/apache/hadoop/hive/ql/io/avro/AvroGenericRecordReader.java index f27cb230b0..e9392a1f29 100644 --- a/ql/src/java/org/apache/hadoop/hive/ql/io/avro/AvroGenericRecordReader.java +++ b/ql/src/java/org/apache/hadoop/hive/ql/io/avro/AvroGenericRecordReader.java @@ -152,13 +152,12 @@ private Schema getSchema(JobConf job, FileSplit split) throws AvroSerdeException } private ZoneId extractWriterTimezoneFromMetadata(JobConf job, FileSplit split, - GenericDatumReader gdr) throws IOException { + GenericDatumReader gdr) { if (job == null || gdr == null || split == null || split.getPath() == null) { return null; } - try { - DataFileReader dataFileReader = - new DataFileReader(new FsInput(split.getPath(), job), gdr); + try (DataFileReader dataFileReader = new DataFileReader( + new FsInput(split.getPath(), job), gdr)) { if (dataFileReader.getMeta(AvroSerDe.WRITER_TIME_ZONE) != null) { try { return ZoneId.of(new String(dataFileReader.getMeta(AvroSerDe.WRITER_TIME_ZONE), @@ -169,6 +168,7 @@ private ZoneId extractWriterTimezoneFromMetadata(JobConf job, FileSplit split, } } catch (IOException e) { // Can't access metadata, carry on. + LOG.debug(e.getMessage(), e); } return null; }