We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
There was an error while loading. Please reload this page.
1 parent da2c82e commit a40db10Copy full SHA for a40db10
sql/core/src/main/scala/org/apache/spark/sql/Dataset.scala
@@ -2173,7 +2173,8 @@ class Dataset[T] private[sql](
2173
!output.exists(f => resolver(f.name, colName))
2174
}.map { case (colName, col) => col.as(colName).named }
2175
2176
- CollapseProject(Project(replacedAndExistingColumns ++ newColumns, logicalPlan))
+ val newPlan = Project(replacedAndExistingColumns ++ newColumns, logicalPlan)
2177
+ CollapseProject(sparkSession.sessionState.analyzer.execute(newPlan))
2178
}
2179
2180
/**
0 commit comments