Skip to content

Commit d518c03

Browse files
zsxwingmarmbrus
authored andcommitted
[HOTFIX] Use 'new Job' in fsBasedParquet.scala
Same issue as #6095 cc liancheng Author: zsxwing <[email protected]> Closes #6136 from zsxwing/hotfix and squashes the following commits: 4beea54 [zsxwing] Use 'new Job' in fsBasedParquet.scala (cherry picked from commit 728af88) Signed-off-by: Michael Armbrust <[email protected]>
1 parent aec8394 commit d518c03

File tree

1 file changed

+1
-1
lines changed

1 file changed

+1
-1
lines changed

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

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -231,7 +231,7 @@ private[sql] class FSBasedParquetRelation(
231231
filters: Array[Filter],
232232
inputPaths: Array[String]): RDD[Row] = {
233233

234-
val job = Job.getInstance(SparkHadoopUtil.get.conf)
234+
val job = new Job(SparkHadoopUtil.get.conf)
235235
val conf = ContextUtil.getConfiguration(job)
236236

237237
ParquetInputFormat.setReadSupportClass(job, classOf[RowReadSupport])

0 commit comments

Comments
 (0)