[cdc] Improve exception message (apache#2271)

liming30 · Nov 7, 2023 · c74987b · c74987b
1 parent 1972d33
commit c74987b
Showing 1 changed file with 5 additions and 2 deletions.
diff --git a/.../src/main/java/org/apache/paimon/flink/sink/cdc/UpdatedDataFieldsProcessFunctionBase.java b/.../src/main/java/org/apache/paimon/flink/sink/cdc/UpdatedDataFieldsProcessFunctionBase.java
@@ -114,8 +114,11 @@ protected void applySchemaChange(
                 case EXCEPTION:
                     throw new UnsupportedOperationException(
                             String.format(
-                                    "Cannot convert field %s from type %s to %s",
-                                    updateColumnType.fieldName(), oldType, newType));
+                                    "Cannot convert field %s from type %s to %s of Paimon table %s.",
+                                    updateColumnType.fieldName(),
+                                    oldType,
+                                    newType,
+                                    identifier.getFullName()));
             }
         } else if (schemaChange instanceof SchemaChange.UpdateColumnComment) {
             catalog.alterTable(identifier, schemaChange, false);