File tree Expand file tree Collapse file tree 1 file changed +2
-7
lines changed
sql/core/src/main/scala/org/apache/spark/sql/parquet Expand file tree Collapse file tree 1 file changed +2
-7
lines changed Original file line number Diff line number Diff line change @@ -185,17 +185,12 @@ private[sql] case class ParquetRelation2(
185
185
val schemaEquality = if (shouldMergeSchemas) {
186
186
shouldMergeSchemas == relation.shouldMergeSchemas
187
187
} else {
188
- schema.sameType(relation.schema)
189
- }
190
-
191
- val maybeSchemaEquality = (maybeMetastoreSchema, relation.maybeMetastoreSchema) match {
192
- case (Some (left), Some (right)) => left.sameType(right)
193
- case (left, right) => left == right
188
+ schema == relation.schema
194
189
}
195
190
196
191
paths.toSet == relation.paths.toSet &&
197
192
schemaEquality &&
198
- maybeSchemaEquality &&
193
+ maybeMetastoreSchema == relation.maybeMetastoreSchema &&
199
194
maybePartitionSpec == relation.maybePartitionSpec
200
195
201
196
case _ => false
You can’t perform that action at this time.
0 commit comments