diff options
| author | zsxwing <zsxwing@gmail.com> | 2015-05-13 17:58:29 -0700 |
|---|---|---|
| committer | Michael Armbrust <michael@databricks.com> | 2015-05-13 17:58:29 -0700 |
| commit | 728af88cf6be4c25a732ab7e4fe66c1ed0041164 (patch) | |
| tree | b4c6c5903905a99f2652e088c6e3739eeebdda90 /sql | |
| parent | 32e27df412706b30daf41f9d46c5572bb9a41bdb (diff) | |
| download | spark-728af88cf6be4c25a732ab7e4fe66c1ed0041164.tar.gz spark-728af88cf6be4c25a732ab7e4fe66c1ed0041164.tar.bz2 spark-728af88cf6be4c25a732ab7e4fe66c1ed0041164.zip | |
[HOTFIX] Use 'new Job' in fsBasedParquet.scala
Same issue as #6095
cc liancheng
Author: zsxwing <zsxwing@gmail.com>
Closes #6136 from zsxwing/hotfix and squashes the following commits:
4beea54 [zsxwing] Use 'new Job' in fsBasedParquet.scala
Diffstat (limited to 'sql')
| -rw-r--r-- | sql/core/src/main/scala/org/apache/spark/sql/parquet/fsBasedParquet.scala | 2 |
1 files changed, 1 insertions, 1 deletions
diff --git a/sql/core/src/main/scala/org/apache/spark/sql/parquet/fsBasedParquet.scala b/sql/core/src/main/scala/org/apache/spark/sql/parquet/fsBasedParquet.scala index d810d6a028..c83a9c35db 100644 --- a/sql/core/src/main/scala/org/apache/spark/sql/parquet/fsBasedParquet.scala +++ b/sql/core/src/main/scala/org/apache/spark/sql/parquet/fsBasedParquet.scala @@ -231,7 +231,7 @@ private[sql] class FSBasedParquetRelation( filters: Array[Filter], inputPaths: Array[String]): RDD[Row] = { - val job = Job.getInstance(SparkHadoopUtil.get.conf) + val job = new Job(SparkHadoopUtil.get.conf) val conf = ContextUtil.getConfiguration(job) ParquetInputFormat.setReadSupportClass(job, classOf[RowReadSupport]) |