diff --git a/common/utils/src/main/resources/error/error-conditions.json b/common/utils/src/main/resources/error/error-conditions.json index 7a5f9bf04d492..8c61f30d25108 100644 --- a/common/utils/src/main/resources/error/error-conditions.json +++ b/common/utils/src/main/resources/error/error-conditions.json @@ -3230,7 +3230,7 @@ }, "INVALID_URL" : { "message" : [ - "The url is invalid: . If necessary set to \"false\" to bypass this error." + "The url is invalid: . Use `try_parse_url` to tolerate invalid URL and return NULL instead." ], "sqlState" : "22P02" }, 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 367d705d9f7dd..63c3c9a7569e2 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 @@ -365,9 +365,7 @@ private[sql] object QueryExecutionErrors extends QueryErrorsBase with ExecutionE def invalidUrlError(url: UTF8String, e: URISyntaxException): SparkIllegalArgumentException = { new SparkIllegalArgumentException( errorClass = "INVALID_URL", - messageParameters = Map( - "url" -> url.toString, - "ansiConfig" -> toSQLConf(SQLConf.ANSI_ENABLED.key)), + messageParameters = Map("url" -> url.toString), cause = e) } diff --git a/sql/core/src/test/scala/org/apache/spark/sql/UrlFunctionsSuite.scala b/sql/core/src/test/scala/org/apache/spark/sql/UrlFunctionsSuite.scala index aeb7101371cda..d6fe01cbf379e 100644 --- a/sql/core/src/test/scala/org/apache/spark/sql/UrlFunctionsSuite.scala +++ b/sql/core/src/test/scala/org/apache/spark/sql/UrlFunctionsSuite.scala @@ -18,7 +18,6 @@ package org.apache.spark.sql import org.apache.spark.SparkIllegalArgumentException -import org.apache.spark.sql.catalyst.util.TypeUtils.toSQLConf import org.apache.spark.sql.internal.SQLConf import org.apache.spark.sql.test.SharedSparkSession @@ -77,10 +76,7 @@ class UrlFunctionsSuite extends QueryTest with SharedSparkSession { sql(s"SELECT parse_url('$url', 'HOST')").collect() }, condition = "INVALID_URL", - parameters = Map( - "url" -> url, - "ansiConfig" -> toSQLConf(SQLConf.ANSI_ENABLED.key) - )) + parameters = Map("url" -> url)) } }