diff --git a/sql/catalyst/src/main/scala/org/apache/spark/sql/errors/QueryErrorsBase.scala b/sql/catalyst/src/main/scala/org/apache/spark/sql/errors/QueryErrorsBase.scala index 5460de77a146f..885b2f775e00c 100644 --- a/sql/catalyst/src/main/scala/org/apache/spark/sql/errors/QueryErrorsBase.scala +++ b/sql/catalyst/src/main/scala/org/apache/spark/sql/errors/QueryErrorsBase.scala @@ -71,7 +71,11 @@ private[sql] trait QueryErrorsBase { } def toSQLId(parts: Seq[String]): String = { - parts.map(quoteIdentifier).mkString(".") + val cleaned = parts match { + case "__auto_generated_subquery_name" :: rest if rest != Nil => rest + case other => other + } + cleaned.map(quoteIdentifier).mkString(".") } def toSQLId(parts: String): String = { diff --git a/sql/core/src/test/resources/sql-tests/analyzer-results/natural-join.sql.out b/sql/core/src/test/resources/sql-tests/analyzer-results/natural-join.sql.out index 8fe2ba77855ba..987fb3e0a09c8 100644 --- a/sql/core/src/test/resources/sql-tests/analyzer-results/natural-join.sql.out +++ b/sql/core/src/test/resources/sql-tests/analyzer-results/natural-join.sql.out @@ -494,7 +494,7 @@ org.apache.spark.sql.AnalysisException "sqlState" : "42703", "messageParameters" : { "objectName" : "`nt2`.`k`", - "proposal" : "`__auto_generated_subquery_name`.`k`, `__auto_generated_subquery_name`.`v1`, `__auto_generated_subquery_name`.`v2`" + "proposal" : "`k`, `v1`, `v2`" }, "queryContext" : [ { "objectType" : "", diff --git a/sql/core/src/test/resources/sql-tests/analyzer-results/pivot.sql.out b/sql/core/src/test/resources/sql-tests/analyzer-results/pivot.sql.out index e5560c04ff1af..d7b77f8ce01fe 100644 --- a/sql/core/src/test/resources/sql-tests/analyzer-results/pivot.sql.out +++ b/sql/core/src/test/resources/sql-tests/analyzer-results/pivot.sql.out @@ -743,7 +743,7 @@ org.apache.spark.sql.AnalysisException "errorClass" : "INCOMPARABLE_PIVOT_COLUMN", "sqlState" : "42818", "messageParameters" : { - "columnName" : "`__auto_generated_subquery_name`.`m`" + "columnName" : "`m`" } } diff --git a/sql/core/src/test/resources/sql-tests/analyzer-results/udf/udf-pivot.sql.out b/sql/core/src/test/resources/sql-tests/analyzer-results/udf/udf-pivot.sql.out index b5f4a6be3b29c..fa94f77207be0 100644 --- a/sql/core/src/test/resources/sql-tests/analyzer-results/udf/udf-pivot.sql.out +++ b/sql/core/src/test/resources/sql-tests/analyzer-results/udf/udf-pivot.sql.out @@ -683,7 +683,7 @@ org.apache.spark.sql.AnalysisException "errorClass" : "INCOMPARABLE_PIVOT_COLUMN", "sqlState" : "42818", "messageParameters" : { - "columnName" : "`__auto_generated_subquery_name`.`m`" + "columnName" : "`m`" } } diff --git a/sql/core/src/test/resources/sql-tests/results/natural-join.sql.out b/sql/core/src/test/resources/sql-tests/results/natural-join.sql.out index 7faa7822c5fda..a8c7ef556fbb7 100644 --- a/sql/core/src/test/resources/sql-tests/results/natural-join.sql.out +++ b/sql/core/src/test/resources/sql-tests/results/natural-join.sql.out @@ -254,7 +254,7 @@ org.apache.spark.sql.AnalysisException "sqlState" : "42703", "messageParameters" : { "objectName" : "`nt2`.`k`", - "proposal" : "`__auto_generated_subquery_name`.`k`, `__auto_generated_subquery_name`.`v1`, `__auto_generated_subquery_name`.`v2`" + "proposal" : "`k`, `v1`, `v2`" }, "queryContext" : [ { "objectType" : "", diff --git a/sql/core/src/test/resources/sql-tests/results/pivot.sql.out b/sql/core/src/test/resources/sql-tests/results/pivot.sql.out index 5c40d1474f693..75eb7c5ab31a8 100644 --- a/sql/core/src/test/resources/sql-tests/results/pivot.sql.out +++ b/sql/core/src/test/resources/sql-tests/results/pivot.sql.out @@ -521,7 +521,7 @@ org.apache.spark.sql.AnalysisException "errorClass" : "INCOMPARABLE_PIVOT_COLUMN", "sqlState" : "42818", "messageParameters" : { - "columnName" : "`__auto_generated_subquery_name`.`m`" + "columnName" : "`m`" } } diff --git a/sql/core/src/test/resources/sql-tests/results/udf/udf-pivot.sql.out b/sql/core/src/test/resources/sql-tests/results/udf/udf-pivot.sql.out index c7e47504b882c..8bd2157b453a9 100644 --- a/sql/core/src/test/resources/sql-tests/results/udf/udf-pivot.sql.out +++ b/sql/core/src/test/resources/sql-tests/results/udf/udf-pivot.sql.out @@ -487,7 +487,7 @@ org.apache.spark.sql.AnalysisException "errorClass" : "INCOMPARABLE_PIVOT_COLUMN", "sqlState" : "42818", "messageParameters" : { - "columnName" : "`__auto_generated_subquery_name`.`m`" + "columnName" : "`m`" } } diff --git a/sql/core/src/test/scala/org/apache/spark/sql/errors/QueryCompilationErrorsSuite.scala b/sql/core/src/test/scala/org/apache/spark/sql/errors/QueryCompilationErrorsSuite.scala index 1c6b8f3e25dc2..7f938deaaa645 100644 --- a/sql/core/src/test/scala/org/apache/spark/sql/errors/QueryCompilationErrorsSuite.scala +++ b/sql/core/src/test/scala/org/apache/spark/sql/errors/QueryCompilationErrorsSuite.scala @@ -486,13 +486,14 @@ class QueryCompilationErrorsSuite sqlState = None, parameters = Map( "objectName" -> "`v`.`i`", - "proposal" -> "`__auto_generated_subquery_name`.`i`"), + "proposal" -> "`i`"), context = ExpectedContext( fragment = "v.i", start = 7, stop = 9)) checkAnswer(sql("SELECT __auto_generated_subquery_name.i from (SELECT i FROM v)"), Row(1)) + checkAnswer(sql("SELECT i from (SELECT i FROM v)"), Row(1)) } } diff --git a/sql/core/src/test/scala/org/apache/spark/sql/errors/QueryExecutionErrorsSuite.scala b/sql/core/src/test/scala/org/apache/spark/sql/errors/QueryExecutionErrorsSuite.scala index 6d2c2600cbb49..61349c38d2b43 100644 --- a/sql/core/src/test/scala/org/apache/spark/sql/errors/QueryExecutionErrorsSuite.scala +++ b/sql/core/src/test/scala/org/apache/spark/sql/errors/QueryExecutionErrorsSuite.scala @@ -420,7 +420,7 @@ class QueryExecutionErrorsSuite checkError( exception = e, errorClass = "INCOMPARABLE_PIVOT_COLUMN", - parameters = Map("columnName" -> "`__auto_generated_subquery_name`.`map`"), + parameters = Map("columnName" -> "`map`"), sqlState = "42818") }