diff --git a/sql/core/src/main/java/org/apache/spark/sql/execution/datasources/parquet/SpecificParquetRecordReaderBase.java b/sql/core/src/main/java/org/apache/spark/sql/execution/datasources/parquet/SpecificParquetRecordReaderBase.java index bf9799bd130a..1cf67dc4af14 100644 --- a/sql/core/src/main/java/org/apache/spark/sql/execution/datasources/parquet/SpecificParquetRecordReaderBase.java +++ b/sql/core/src/main/java/org/apache/spark/sql/execution/datasources/parquet/SpecificParquetRecordReaderBase.java @@ -133,7 +133,7 @@ public void initialize(InputSplit inputSplit, TaskAttemptContext taskAttemptCont this.readSupport = getReadSupportInstance( (Class>) getReadSupportClass(configuration)); ReadSupport.ReadContext readContext = readSupport.init(new InitContext( - taskAttemptContext.getConfiguration(), toSetMultiMap(fileMetadata), fileSchema)); + configuration, toSetMultiMap(fileMetadata), fileSchema)); this.requestedSchema = readContext.getRequestedSchema(); this.fileSchema = fileSchema; this.reader = new ParquetFileReader(configuration, file, blocks, requestedSchema.getColumns());