From 89484095af50464c6f50617e7750068a4847afc7 Mon Sep 17 00:00:00 2001 From: Josh Rosen Date: Mon, 8 Feb 2016 23:40:30 -0800 Subject: [PATCH] [SPARK-12921] Fix another non-reflective TaskAttemptContext access in SpecificParquetRecordReaderBase --- .../datasources/parquet/SpecificParquetRecordReaderBase.java | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) 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());