File tree Expand file tree Collapse file tree 1 file changed +4
-4
lines changed
sql/hive/src/main/scala/org/apache/spark/sql/hive Expand file tree Collapse file tree 1 file changed +4
-4
lines changed Original file line number Diff line number Diff line change @@ -208,14 +208,14 @@ private[hive] class HiveMetastoreCatalog(hive: HiveContext) extends Catalog with
208
208
ParquetRelation2 (
209
209
paths,
210
210
Map (ParquetRelation2 .METASTORE_SCHEMA -> metastoreSchema.json),
211
- Some (metastoreSchema) ,
211
+ None ,
212
212
Some (partitionSpec))(hive))
213
213
} else {
214
214
val paths = Seq (metastoreRelation.hiveQlTable.getDataLocation.toString)
215
- LogicalRelation (ParquetRelation2 (
215
+ LogicalRelation (
216
+ ParquetRelation2 (
216
217
paths,
217
- Map (ParquetRelation2 .METASTORE_SCHEMA -> metastoreSchema.json),
218
- Some (metastoreSchema))(hive))
218
+ Map (ParquetRelation2 .METASTORE_SCHEMA -> metastoreSchema.json))(hive))
219
219
}
220
220
}
221
221
You can’t perform that action at this time.
0 commit comments