fix

Author: zml1206

flink-cdc-connect/flink-cdc-pipeline-connectors/flink-cdc-pipeline-connector-starrocks/src/main/java/org/apache/flink/cdc/connectors/starrocks/sink/StarRocksEnrichedCatalog.java

@@ -50,19 +50,19 @@ public void createTable(StarRocksTable table, boolean ignoreIfExists)
             LOG.info(
                     "Success to create table {}.{}, sql: {}",
                     table.getDatabaseName(),
-                    table.getDatabaseName(),
+                    table.getTableName(),
                     createTableSql);
         } catch (Exception e) {
             LOG.error(
                     "Failed to create table {}.{}, sql: {}",
                     table.getDatabaseName(),
-                    table.getDatabaseName(),
+                    table.getTableName(),
                     createTableSql,
                     e);
             throw new StarRocksCatalogException(
                     String.format(
                             "Failed to create table %s.%s",
-                            table.getDatabaseName(), table.getDatabaseName()),
+                            table.getDatabaseName(), table.getTableName()),
                     e);
         }
     }

flink-cdc-connect/flink-cdc-pipeline-connectors/flink-cdc-pipeline-connector-starrocks/src/test/java/org/apache/flink/cdc/connectors/starrocks/sink/StarRocksMetadataApplierITCase.java

@@ -103,7 +103,10 @@ private List<Event> generateAddColumnEvents(TableId tableId) {
                         .column(new PhysicalColumn("number", DataTypes.DOUBLE(), null))
                         .column(
                                 new PhysicalColumn(
-                                        "name", DataTypes.VARCHAR(17), "\"name\"", "\"\""))
+                                        "name",
+                                        DataTypes.VARCHAR(17),
+                                        "\"name\"",
+                                        "\"name\\\\default\""))
                         .primaryKey("id")
                         .build();
 
@@ -134,7 +137,7 @@ private List<Event> generateAddColumnEvents(TableId tableId) {
                                                 "extra_string",
                                                 DataTypes.VARCHAR(17),
                                                 "\"extra_string\"",
-                                                "\"\"")))));
+                                                "\"extra\\\\string\"")))));
     }
 
     private List<Event> generateDropColumnEvents(TableId tableId) {
@@ -294,11 +297,11 @@ void testStarRocksAddColumn() throws Exception {
                 Arrays.asList(
                         "id | int | NO | true | null",
                         "number | double | YES | false | null",
-                        "name | varchar(51) | YES | false | \"\"",
+                        "name | varchar(51) | YES | false | \"name\\\\default\"",
                         "extra_date | date | YES | false | null",
                         "extra_bool | boolean | YES | false | null",
                         "extra_decimal | decimal(17,0) | YES | false | null",
-                        "extra_string | varchar(51) | YES | false | \"\"");
+                        "extra_string | varchar(51) | YES | false | \"extra\\\\string\"");
 
         assertEqualsInOrder(expected, actual);
     }