Skip to content

Commit 295acc9

Browse files
committed
address comments
1 parent 9305187 commit 295acc9

File tree

2 files changed

+2
-2
lines changed

2 files changed

+2
-2
lines changed

sql/catalyst/src/main/scala/org/apache/spark/sql/catalyst/plans/QueryPlan.scala

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -391,7 +391,7 @@ abstract class QueryPlan[PlanType <: QueryPlan[PlanType]] extends TreeNode[PlanT
391391

392392
/**
393393
* Do some simple transformation on this plan before canonicalizing. Implementations can override
394-
* this method to provide customer canonicalize logic without rewriting the whole logic.
394+
* this method to provide customized canonicalize logic without rewriting the whole logic.
395395
*/
396396
protected def preCanonicalized: PlanType = this
397397

sql/core/src/main/scala/org/apache/spark/sql/execution/DataSourceScanExec.scala

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -265,7 +265,7 @@ case class FileSourceScanExec(
265265
val metadata =
266266
Map(
267267
"Format" -> relation.fileFormat.toString,
268-
"requiredSchema" -> requiredSchema.catalogString,
268+
"ReadSchema" -> requiredSchema.catalogString,
269269
"Batched" -> supportsBatch.toString,
270270
"PartitionFilters" -> seqToString(partitionFilters),
271271
"PushedFilters" -> seqToString(pushedDownFilters),

0 commit comments

Comments
 (0)