diff --git a/src/main/java/com/starrocks/connector/flink/catalog/StarRocksCatalog.java b/src/main/java/com/starrocks/connector/flink/catalog/StarRocksCatalog.java
index 403f8ac64..cca5eaee2 100644
--- a/src/main/java/com/starrocks/connector/flink/catalog/StarRocksCatalog.java
+++ b/src/main/java/com/starrocks/connector/flink/catalog/StarRocksCatalog.java
@@ -284,14 +284,14 @@ public void createTable(StarRocksTable table, boolean ignoreIfExists)
         try {
             executeUpdateStatement(createTableSql);
             LOG.info("Success to create table {}.{}, sql: {}",
-                    table.getDatabaseName(), table.getDatabaseName(), createTableSql);
+                    table.getDatabaseName(), table.getTableName(), createTableSql);
         } catch (Exception e) {
             LOG.error("Failed to create table {}.{}, sql: {}",
-                    table.getDatabaseName(), table.getDatabaseName(), createTableSql, e);
+                    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);
         }
     }