diff --git a/common/utils/src/main/resources/error/error-conditions.json b/common/utils/src/main/resources/error/error-conditions.json index 31c10f9b9aac..1b1b68b5b518 100644 --- a/common/utils/src/main/resources/error/error-conditions.json +++ b/common/utils/src/main/resources/error/error-conditions.json @@ -5315,6 +5315,11 @@ "message" : [ "Update column nullability for MySQL and MS SQL Server." ] + }, + "WRITE_FOR_BINARY_SOURCE" : { + "message" : [ + "Write for the binary file data source." + ] } }, "sqlState" : "0A000" @@ -7016,11 +7021,6 @@ "user-specified schema." ] }, - "_LEGACY_ERROR_TEMP_2075" : { - "message" : [ - "Write is not supported for binary file data source." - ] - }, "_LEGACY_ERROR_TEMP_2076" : { "message" : [ "The length of is , which exceeds the max length allowed: ." 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 a32016eee61f..3a4d740d8f15 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 @@ -914,7 +914,7 @@ private[sql] object QueryExecutionErrors extends QueryErrorsBase with ExecutionE } def writeUnsupportedForBinaryFileDataSourceError(): SparkUnsupportedOperationException = { - new SparkUnsupportedOperationException("_LEGACY_ERROR_TEMP_2075") + new SparkUnsupportedOperationException("UNSUPPORTED_FEATURE.WRITE_FOR_BINARY_SOURCE") } def fileLengthExceedsMaxLengthError(status: FileStatus, maxLength: Int): Throwable = { diff --git a/sql/core/src/test/scala/org/apache/spark/sql/execution/datasources/binaryfile/BinaryFileFormatSuite.scala b/sql/core/src/test/scala/org/apache/spark/sql/execution/datasources/binaryfile/BinaryFileFormatSuite.scala index 387a2baa256b..62f2f2cb10a8 100644 --- a/sql/core/src/test/scala/org/apache/spark/sql/execution/datasources/binaryfile/BinaryFileFormatSuite.scala +++ b/sql/core/src/test/scala/org/apache/spark/sql/execution/datasources/binaryfile/BinaryFileFormatSuite.scala @@ -168,7 +168,7 @@ class BinaryFileFormatSuite extends QueryTest with SharedSparkSession { .format(BINARY_FILE) .save(s"$tmpDir/test_save") }, - condition = "_LEGACY_ERROR_TEMP_2075", + condition = "UNSUPPORTED_FEATURE.WRITE_FOR_BINARY_SOURCE", parameters = Map.empty) } }