bug fix

lazyman500 · lazyman500 · commit f23133fde4da · 2015-03-18T19:41:52.000+08:00
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
@@ -180,7 +180,8 @@ class HadoopTableReader(
       }
     }
 
-    val hivePartitionRDDs = verifyPartitionPath(partitionToDeserializer).map {
+    val hivePartitionRDDs = verifyPartitionPath(partitionToDeserializer)
+      .map { case (partition, partDeserializer) =>
       val partDesc = Utilities.getPartitionDesc(partition)
       val partPath = HiveShim.getDataLocationPath(partition)
       val inputPathStr = applyFilterIfNeeded(partPath, filterOpt)

Original file line number	Diff line number	Diff line change
`@@ -180,7 +180,8 @@ class HadoopTableReader(`
`180`	`180`	`}`
`181`	`181`	`}`
`182`	`182`
`183`		`- val hivePartitionRDDs = verifyPartitionPath(partitionToDeserializer).map {`
	`183`	`+ val hivePartitionRDDs = verifyPartitionPath(partitionToDeserializer)`
	`184`	`+ .map { case (partition, partDeserializer) =>`
`184`	`185`	`val partDesc = Utilities.getPartitionDesc(partition)`
`185`	`186`	`val partPath = HiveShim.getDataLocationPath(partition)`
`186`	`187`	`val inputPathStr = applyFilterIfNeeded(partPath, filterOpt)`