diff --git a/ql/src/java/org/apache/hadoop/hive/ql/io/parquet/vector/VectorizedParquetRecordReader.java b/ql/src/java/org/apache/hadoop/hive/ql/io/parquet/vector/VectorizedParquetRecordReader.java index 6ca1963f94..312cdacff3 100644 --- a/ql/src/java/org/apache/hadoop/hive/ql/io/parquet/vector/VectorizedParquetRecordReader.java +++ b/ql/src/java/org/apache/hadoop/hive/ql/io/parquet/vector/VectorizedParquetRecordReader.java @@ -121,8 +121,9 @@ public VectorizedParquetRecordReader( try { serDeStats = new SerDeStats(); projectionPusher = new ProjectionPusher(); - if (oldInputSplit != null) { - initialize(getSplit(oldInputSplit, conf), conf); + ParquetInputSplit inputSplit = getSplit(oldInputSplit, conf); + if (inputSplit != null) { + initialize(inputSplit, conf); setTimeZoneConversion(jobConf, ((FileSplit) oldInputSplit).getPath()); } colsToInclude = ColumnProjectionUtils.getReadColumnIDs(conf);