diff --git a/sql/core/src/main/scala/org/apache/spark/sql/sources/commands.scala b/sql/core/src/main/scala/org/apache/spark/sql/sources/commands.scala index 127133bfaf662..8372d2c34acc7 100644 --- a/sql/core/src/main/scala/org/apache/spark/sql/sources/commands.scala +++ b/sql/core/src/main/scala/org/apache/spark/sql/sources/commands.scala @@ -88,7 +88,7 @@ private[sql] case class InsertIntoFSBasedRelation( } if (doInsertion) { - val job = Job.getInstance(hadoopConf) + val job = new Job(hadoopConf) job.setOutputKeyClass(classOf[Void]) job.setOutputValueClass(classOf[Row]) FileOutputFormat.setOutputPath(job, qualifiedOutputPath)