add errorAdditionalAttributeTable

Author: dtunikov

flow/alerting/classifier.go

@@ -1122,10 +1122,13 @@ func GetErrorClass(ctx context.Context, err error) (ErrorClass, ErrorInfo) {
 		}
 	}
 
-	if _, ok := errors.AsType[*exceptions.MySQLUnsupportedBinlogRowValueOptionsError](err); ok {
+	if partialJsonUnsupportedError, ok := errors.AsType[*exceptions.MySQLUnsupportedBinlogRowValueOptionsError](err); ok {
 		return ErrorNotifyBinlogPartialJsonUnsupported, ErrorInfo{
 			Source: ErrorSourceMySQL,
-			Code:   "UNSUPPORTED_BINLOG_ROW_VALUE_OPTIONS",
+			Code:   "UNSUPPORTED_PARTIAL_JSON",
+			AdditionalAttributes: map[AdditionalErrorAttributeKey]string{
+				ErrorAttributeKeyTable: fmt.Sprintf("%s.%s", partialJsonUnsupportedError.Schema, partialJsonUnsupportedError.Table),
+			},
 		}
 	}
 

flow/alerting/classifier_test.go

@@ -1252,6 +1252,9 @@ func TestMySQLUnsupportedBinlogRowValueOptionsErrorShouldBeNotifyBinlogPartialJs
 	assert.Equal(t, ErrorNotifyBinlogPartialJsonUnsupported, errorClass)
 	assert.Equal(t, ErrorInfo{
 		Source: ErrorSourceMySQL,
-		Code:   "UNSUPPORTED_BINLOG_ROW_VALUE_OPTIONS",
+		Code:   "UNSUPPORTED_PARTIAL_JSON",
+		AdditionalAttributes: map[AdditionalErrorAttributeKey]string{
+			ErrorAttributeKeyTable: "mydb.mytable",
+		},
 	}, errInfo)
 }

flow/shared/exceptions/mysql.go

@@ -56,18 +56,18 @@ func (e *MySQLUnsupportedBinlogRowMetadataError) Error() string {
 }
 
 type MySQLUnsupportedBinlogRowValueOptionsError struct {
-	SchemaName string
-	TableName  string
+	Schema string
+	Table  string
 }
 
 func NewMySQLUnsupportedBinlogRowValueOptionsError(schema string, table string) *MySQLUnsupportedBinlogRowValueOptionsError {
-	return &MySQLUnsupportedBinlogRowValueOptionsError{SchemaName: schema, TableName: table}
+	return &MySQLUnsupportedBinlogRowValueOptionsError{Schema: schema, Table: table}
 }
 
 func (e *MySQLUnsupportedBinlogRowValueOptionsError) Error() string {
 	return fmt.Sprintf(
 		"Received a partial JSON update event while processing %s.%s; binlog_row_value_options must be disabled (set to '')",
-		e.SchemaName, e.TableName)
+		e.Schema, e.Table)
 }
 
 type MySQLUnsupportedDDLError struct {