diff --git a/common/utils/src/main/resources/error/error-conditions.json b/common/utils/src/main/resources/error/error-conditions.json index 8e7125a07c1e8..97b66b23dd866 100644 --- a/common/utils/src/main/resources/error/error-conditions.json +++ b/common/utils/src/main/resources/error/error-conditions.json @@ -10113,11 +10113,6 @@ "Sinks cannot request distribution and ordering in continuous execution mode." ] }, - "_LEGACY_ERROR_TEMP_2003" : { - "message" : [ - "Unsuccessful try to zip maps with unique keys due to exceeding the array size limit ." - ] - }, "_LEGACY_ERROR_TEMP_2017" : { "message" : [ "not resolved." 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 48c3ef0c6a936..c8cf9eb701f95 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 @@ -342,12 +342,10 @@ private[sql] object QueryExecutionErrors extends QueryErrorsBase with ExecutionE arithmeticOverflowError("Overflow in function conv()", context = context) } - def mapSizeExceedArraySizeWhenZipMapError(size: Int): SparkRuntimeException = { - new SparkRuntimeException( - errorClass = "_LEGACY_ERROR_TEMP_2003", - messageParameters = Map( - "size" -> size.toString(), - "maxRoundedArrayLength" -> ByteArrayMethods.MAX_ROUNDED_ARRAY_LENGTH.toString())) + def mapSizeExceedArraySizeWhenZipMapError(size: Int): SparkException = { + SparkException.internalError( + s"Unsuccessful try to zip maps with $size unique keys due to exceeding the array size " + + s"limit ${ByteArrayMethods.MAX_ROUNDED_ARRAY_LENGTH}.") } def literalTypeUnsupportedError(v: Any): RuntimeException = {