fix comments

Signed-off-by: Pei Yu <125331682@qq.com>

Author: sd4324530

flink-cdc-common/src/main/java/org/apache/flink/cdc/common/utils/SchemaUtils.java

@@ -144,9 +144,9 @@ private static Schema applyAddColumnEvent(AddColumnEvent event, Schema oldSchema
                         if (index < 0) {
                             throw new IllegalArgumentException(
                                     String.format(
-                                            "BEFORE type AddColumnEvent error: Table %s's column %s is not existed",
-                                            event.tableId(),
-                                            columnWithPosition.getExistedColumnName()));
+                                            "BEFORE type AddColumnEvent error: Column %s does not exist in table %s",
+                                            columnWithPosition.getExistedColumnName(),
+                                            event.tableId()));
                         }
                         columns.add(index, columnWithPosition.getAddColumn());
                         break;
@@ -162,9 +162,9 @@ private static Schema applyAddColumnEvent(AddColumnEvent event, Schema oldSchema
                         if (index < 0) {
                             throw new IllegalArgumentException(
                                     String.format(
-                                            "AFTER type AddColumnEvent error: Table %s's column %s is not existed",
-                                            event.tableId(),
-                                            columnWithPosition.getExistedColumnName()));
+                                            "AFTER type AddColumnEvent error: Column %s does not exist in table %s",
+                                            columnWithPosition.getExistedColumnName(),
+                                            event.tableId()));
                         }
                         columns.add(index + 1, columnWithPosition.getAddColumn());
                         break;

flink-cdc-common/src/test/java/org/apache/flink/cdc/common/utils/SchemaUtilsTest.java

@@ -138,8 +138,8 @@ void testApplyColumnSchemaChangeEvent() {
                 .isExactlyInstanceOf(IllegalArgumentException.class)
                 .hasMessage(
                         String.format(
-                                "BEFORE type AddColumnEvent error: Table %s's column %s is not existed",
-                                tableId, "col10"));
+                                "BEFORE type AddColumnEvent error: Column %s does not exist in table %s",
+                                "col10", tableId));
 
         // wrong add column in after type
         Assertions.assertThatThrownBy(
@@ -157,8 +157,8 @@ void testApplyColumnSchemaChangeEvent() {
                 .isExactlyInstanceOf(IllegalArgumentException.class)
                 .hasMessage(
                         String.format(
-                                "AFTER type AddColumnEvent error: Table %s's column %s is not existed",
-                                tableId, "col10"));
+                                "AFTER type AddColumnEvent error: Column %s does not exist in table %s",
+                                "col10", tableId));
 
         // drop columns
         DropColumnEvent dropColumnEvent =