You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@spark.apache.org by jo...@apache.org on 2016/02/10 20:02:54 UTC
spark git commit: [SPARK-12921] Fix another non-reflective
TaskAttemptContext access in SpecificParquetRecordReaderBase
Repository: spark
Updated Branches:
refs/heads/branch-1.6 89818cbf8 -> 93f1d9175
[SPARK-12921] Fix another non-reflective TaskAttemptContext access in SpecificParquetRecordReaderBase
This is a minor followup to #10843 to fix one remaining place where we forgot to use reflective access of TaskAttemptContext methods.
Author: Josh Rosen <jo...@databricks.com>
Closes #11131 from JoshRosen/SPARK-12921-take-2.
Project: http://git-wip-us.apache.org/repos/asf/spark/repo
Commit: http://git-wip-us.apache.org/repos/asf/spark/commit/93f1d917
Tree: http://git-wip-us.apache.org/repos/asf/spark/tree/93f1d917
Diff: http://git-wip-us.apache.org/repos/asf/spark/diff/93f1d917
Branch: refs/heads/branch-1.6
Commit: 93f1d91755475a242456fe06e57bfca10f4d722f
Parents: 89818cb
Author: Josh Rosen <jo...@databricks.com>
Authored: Wed Feb 10 11:02:41 2016 -0800
Committer: Josh Rosen <jo...@databricks.com>
Committed: Wed Feb 10 11:02:41 2016 -0800
----------------------------------------------------------------------
.../datasources/parquet/SpecificParquetRecordReaderBase.java | 2 +-
1 file changed, 1 insertion(+), 1 deletion(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/spark/blob/93f1d917/sql/core/src/main/java/org/apache/spark/sql/execution/datasources/parquet/SpecificParquetRecordReaderBase.java
----------------------------------------------------------------------
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 bf9799b..1cf67dc 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 abstract class SpecificParquetRecordReaderBase<T> extends RecordReader<Vo
this.readSupport = getReadSupportInstance(
(Class<? extends ReadSupport<T>>) 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());
---------------------------------------------------------------------
To unsubscribe, e-mail: commits-unsubscribe@spark.apache.org
For additional commands, e-mail: commits-help@spark.apache.org