ODIn/spark-instrumented-optimizer
1
0
Fork 0
Code Issues Pull requests Projects Releases Wiki Activity

[HOTFIX] Use 'new Job' in fsBasedParquet.scala

Browse source 
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
This commit is contained in:
zsxwing 2015-05-13 17:58:29 -07:00 committed by Michael Armbrust
parent 32e27df412
commit 728af88cf6
1 changed files with 1 additions and 1 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

2
sql/core/src/main/scala/org/apache/spark/sql/parquet/fsBasedParquet.scala
View file

@ -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])