Github user HyukjinKwon commented on a diff in the pull request:
https://github.com/apache/spark/pull/22208#discussion_r212788594
--- Diff: sql/core/src/main/scala/org/apache/spark/sql/Dataset.scala ---
@@ -216,8 +216,16 @@ class Dataset[T] private[sql](
private[sql] def resolve(colName: String): NamedExpression = {
queryExecution.analyzed.resolveQuoted(colName,
sparkSession.sessionState.analyzer.resolver)
.getOrElse {
- throw new AnalysisException(
- s"""Cannot resolve column name "$colName" among
(${schema.fieldNames.mkString(", ")})""")
+ if (schema.fieldNames.contains(colName)) {
+ throw new AnalysisException(
+ s"""Cannot resolve column name "$colName" among
(${schema.fieldNames.mkString(", ")}).
+ | Try adding backticks to the column name, i.e.,
`$colName`"""
--- End diff --
Yup, please go ahead.
---
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
