use setInputPaths(Job job, Path... inputPaths)

apache · Feb 26, 2015 · 1db1a1c · 1db1a1c
1 parent b788a72
commit 1db1a1c
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/sql/hive/src/main/scala/org/apache/spark/sql/hive/TableReader.scala b/sql/hive/src/main/scala/org/apache/spark/sql/hive/TableReader.scala
@@ -249,7 +249,7 @@ private[hive] object HadoopTableReader extends HiveInspectors {
    * instantiate a HadoopRDD.
    */
   def initializeLocalJobConfFunc(path: String, tableDesc: TableDesc)(jobConf: JobConf) {
-    jobConf.set("mapred.input.dir", StringUtils.escapeString(path.toString()))
+    FileInputFormat.setInputPaths(jobConf, Seq[Path](path): _*)
     if (tableDesc != null) {
       PlanUtils.configureInputJobPropertiesForStorageHandler(tableDesc)
       Utilities.copyTableJobPropertiesToConf(tableDesc, jobConf)