[HOTFIX] Use the old Job API to support old Hadoop versions

zsxwing · liancheng · commit 2cc330181238 · 2015-05-13T08:33:43.000+08:00
#5526 uses `Job.getInstance`, which does not exist in the old Hadoop versions. Just use `new Job` to replace it. cc liancheng Author: zsxwing <zsxwing@gmail.com> Closes #6095 from zsxwing/hotfix and squashes the following commits: b0c2049 [zsxwing] Use the old Job API to support old Hadoop versions (cherry picked from commit 247b703) Signed-off-by: Cheng Lian <lian@databricks.com>
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)`