From d8dd8fc478f49f456ff97e6d94b7d8c763efe2e3 Mon Sep 17 00:00:00 2001
From: zhyayun <zhyayun@outlook.com>
Date: Fri, 21 Feb 2025 17:04:16 +0800
Subject: [PATCH] [BugFix]Fixed an issue where table names were printed
 incorrectly after creating a table in StarRocksCatalog.

---
 .../starrocks/connector/flink/catalog/StarRocksCatalog.java | 6 +++---
 1 file changed, 3 insertions(+), 3 deletions(-)

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);
         }
     }