Github user cloud-fan commented on a diff in the pull request:
https://github.com/apache/spark/pull/22320#discussion_r214645372
--- Diff:
sql/core/src/main/scala/org/apache/spark/sql/execution/datasources/DataSource.scala
---
@@ -495,7 +496,9 @@ case class DataSource(
s"Unable to resolve $name given
[${data.output.map(_.name).mkString(", ")}]")
}
}
- val resolved = cmd.copy(partitionColumns = resolvedPartCols,
outputColumns = outputColumns)
+ val resolved = cmd.copy(
+ partitionColumns = resolvedPartCols,
+ outputColumnNames = outputColumns.map(_.name))
--- End diff --
why can't we use `outputColumnNames` directly here?
---
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
