diff options
| author | zsxwing <zsxwing@gmail.com> | 2015-05-13 08:33:24 +0800 |
|---|---|---|
| committer | Cheng Lian <lian@databricks.com> | 2015-05-13 08:33:24 +0800 |
| commit | 247b70349c1e4413657359d626d92e0ffbc2b7f1 (patch) | |
| tree | d8ddbc4e4c781af618a04e031842ce119e5beac8 /sql | |
| parent | 77f64c736d07a44f64393910d092091e8ba6047a (diff) | |
| download | spark-247b70349c1e4413657359d626d92e0ffbc2b7f1.tar.gz spark-247b70349c1e4413657359d626d92e0ffbc2b7f1.tar.bz2 spark-247b70349c1e4413657359d626d92e0ffbc2b7f1.zip | |
[HOTFIX] Use the old Job API to support old Hadoop versions
#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
Diffstat (limited to 'sql')
| -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) |