anew commented on code in PR #56686:
URL: https://github.com/apache/spark/pull/56686#discussion_r3552995539
##########
common/utils/src/main/resources/error/error-conditions.json:
##########
@@ -211,27 +211,32 @@
},
"AUTOCDC_INVALID_STATE" : {
"message" : [
- "AutoCDC flow <flowName> detected an invalid state:"
+ "Detected an invalid AutoCDC state for target table <tableName>:"
],
"subClass" : {
"AUXILIARY_TABLE_KEY_COLUMN_MISSING" : {
"message" : [
- "The auxiliary table <auxTableName> is missing key column
<keyColumnName> that is recorded in its <propertyName> table property. The
auxiliary table schema may be corrupted or have been modified externally.
Perform a full refresh of the target table to recreate the auxiliary table."
+ "The internal auxiliary table is missing key column <keyColumnName>
that is recorded in its <propertyName> table property. The auxiliary table
schema may be corrupted or have been modified externally. Perform a full
refresh of the target table to recreate the auxiliary table."
Review Comment:
The target table name is already in the rendered error — it's carried by the
parent `AUTOCDC_INVALID_STATE` message ("Detected an invalid AutoCDC state
for
target table <tableName>:"), which Spark prepends to each subclass message.
So
e.g. the full text a user sees is:
> Detected an invalid AutoCDC state for target table `cat`.`db`.`t`: The
> internal auxiliary table is missing key column ...
Same for the other messages
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
To unsubscribe, e-mail: [email protected]
For queries about this service, please contact Infrastructure at:
[email protected]
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
