Github user MaxGekk commented on a diff in the pull request:
https://github.com/apache/spark/pull/21720#discussion_r200837087
--- Diff:
sql/catalyst/src/main/scala/org/apache/spark/sql/catalyst/analysis/Analyzer.scala
---
@@ -506,7 +506,7 @@ class Analyzer(
def apply(plan: LogicalPlan): LogicalPlan = plan transform {
case p: Pivot if !p.childrenResolved ||
!p.aggregates.forall(_.resolved)
|| (p.groupByExprsOpt.isDefined &&
!p.groupByExprsOpt.get.forall(_.resolved))
- || !p.pivotColumn.resolved => p
+ || !p.pivotColumn.resolved || !p.pivotValues.forall(_.resolved) =>
p
--- End diff --
By which test is the change covered?
---
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
