Use the old Job API to support old Hadoop versions

zsxwing · zsxwing · commit b0c204945e86 · 2015-05-12T13:23:54.000-07:00
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
@@ -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)

Original file line number	Diff line number	Diff line change
`@@ -88,7 +88,7 @@ private[sql] case class InsertIntoFSBasedRelation(`
`88`	`88`	`}`
`89`	`89`
`90`	`90`	`if (doInsertion) {`
`91`		`- val job = Job.getInstance(hadoopConf)`
	`91`	`+ val job = new Job(hadoopConf)`
`92`	`92`	`job.setOutputKeyClass(classOf[Void])`
`93`	`93`	`job.setOutputValueClass(classOf[Row])`
`94`	`94`	`FileOutputFormat.setOutputPath(job, qualifiedOutputPath)`