diff options
| -rw-r--r-- | sql/core/src/main/scala/org/apache/spark/sql/sources/commands.scala | 2 |
1 files changed, 1 insertions, 1 deletions
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 127133bfaf..8372d2c34a 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) |