diff --git a/common/utils/src/main/resources/error/error-conditions.json b/common/utils/src/main/resources/error/error-conditions.json index 18603b61d8ae1..2aecb55121e3f 100644 --- a/common/utils/src/main/resources/error/error-conditions.json +++ b/common/utils/src/main/resources/error/error-conditions.json @@ -5421,6 +5421,12 @@ }, "sqlState" : "42902" }, + "UNSUPPORTED_PARTITION_TRANSFORM" : { + "message" : [ + "Unsupported partition transform: . The supported transforms are `identity`, `bucket`, and `clusterBy`. Ensure your transform expression uses one of these." + ], + "sqlState" : "0A000" + }, "UNSUPPORTED_SAVE_MODE" : { "message" : [ "The save mode is not supported for:" @@ -6974,11 +6980,6 @@ "Invalid namespace name: ." ] }, - "_LEGACY_ERROR_TEMP_2067" : { - "message" : [ - "Unsupported partition transform: ." - ] - }, "_LEGACY_ERROR_TEMP_2068" : { "message" : [ "Missing database location." diff --git a/sql/catalyst/src/main/scala/org/apache/spark/sql/errors/QueryExecutionErrors.scala b/sql/catalyst/src/main/scala/org/apache/spark/sql/errors/QueryExecutionErrors.scala index 2cc223ba69fa7..95acfe7983027 100644 --- a/sql/catalyst/src/main/scala/org/apache/spark/sql/errors/QueryExecutionErrors.scala +++ b/sql/catalyst/src/main/scala/org/apache/spark/sql/errors/QueryExecutionErrors.scala @@ -871,8 +871,8 @@ private[sql] object QueryExecutionErrors extends QueryErrorsBase with ExecutionE def unsupportedPartitionTransformError( transform: Transform): SparkUnsupportedOperationException = { new SparkUnsupportedOperationException( - errorClass = "_LEGACY_ERROR_TEMP_2067", - messageParameters = Map("transform" -> transform.toString())) + errorClass = "UNSUPPORTED_PARTITION_TRANSFORM", + messageParameters = Map("transform" -> toSQLId(transform.toString))) } def missingDatabaseLocationError(): SparkIllegalArgumentException = { diff --git a/sql/core/src/test/scala/org/apache/spark/sql/execution/command/PlanResolutionSuite.scala b/sql/core/src/test/scala/org/apache/spark/sql/execution/command/PlanResolutionSuite.scala index 5a4d7c86761fe..92467cbcb6c05 100644 --- a/sql/core/src/test/scala/org/apache/spark/sql/execution/command/PlanResolutionSuite.scala +++ b/sql/core/src/test/scala/org/apache/spark/sql/execution/command/PlanResolutionSuite.scala @@ -306,8 +306,8 @@ class PlanResolutionSuite extends AnalysisTest { exception = intercept[SparkUnsupportedOperationException] { parseAndResolve(query) }, - condition = "_LEGACY_ERROR_TEMP_2067", - parameters = Map("transform" -> transform)) + condition = "UNSUPPORTED_PARTITION_TRANSFORM", + parameters = Map("transform" -> toSQLId(transform))) } }