We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
There was an error while loading. Please reload this page.
1 parent 61d1e87 commit 4beea54Copy full SHA for 4beea54
sql/core/src/main/scala/org/apache/spark/sql/parquet/fsBasedParquet.scala
@@ -231,7 +231,7 @@ private[sql] class FSBasedParquetRelation(
231
filters: Array[Filter],
232
inputPaths: Array[String]): RDD[Row] = {
233
234
- val job = Job.getInstance(SparkHadoopUtil.get.conf)
+ val job = new Job(SparkHadoopUtil.get.conf)
235
val conf = ContextUtil.getConfiguration(job)
236
237
ParquetInputFormat.setReadSupportClass(job, classOf[RowReadSupport])
0 commit comments