diff --git a/common/utils/src/main/resources/error/error-classes.json b/common/utils/src/main/resources/error/error-classes.json index 3144871ea8051..c3e10e6c5fb21 100644 --- a/common/utils/src/main/resources/error/error-classes.json +++ b/common/utils/src/main/resources/error/error-classes.json @@ -7720,6 +7720,11 @@ "Failed to parse a value for data type
with event " ] }, + "_LEGACY_ERROR_TEMP_3241" : { + "message" : [ + "" + ] + }, "_LEGACY_ERROR_USER_RAISED_EXCEPTION" : { "message" : [ "" diff --git a/sql/catalyst/src/main/scala/org/apache/spark/sql/catalyst/csv/CSVHeaderChecker.scala b/sql/catalyst/src/main/scala/org/apache/spark/sql/catalyst/csv/CSVHeaderChecker.scala index 9366c62792c8c..43336dbfa65c0 100644 --- a/sql/catalyst/src/main/scala/org/apache/spark/sql/catalyst/csv/CSVHeaderChecker.scala +++ b/sql/catalyst/src/main/scala/org/apache/spark/sql/catalyst/csv/CSVHeaderChecker.scala @@ -19,6 +19,7 @@ package org.apache.spark.sql.catalyst.csv import com.univocity.parsers.csv.CsvParser +import org.apache.spark.SparkIllegalArgumentException import org.apache.spark.internal.Logging import org.apache.spark.sql.internal.SQLConf import org.apache.spark.sql.types.StructType @@ -92,7 +93,9 @@ class CSVHeaderChecker( if (enforceSchema) { logWarning(msg) } else { - throw new IllegalArgumentException(msg) + throw new SparkIllegalArgumentException( + errorClass = "_LEGACY_ERROR_TEMP_3241", + messageParameters = Map("msg" -> msg)) } } }