-
Notifications
You must be signed in to change notification settings - Fork 191
Closed
Description
StarRocksCatalog createTable function log is incorrect, it should print ${dbName}.${tableName} but it prints${dbName}.${dbName}.
https://github.com/beryllw/starrocks-connector-for-apache-flink/blob/fcc130ca1eb640bc1b28cefdd0ee3b420bd72d8a/src/main/java/com/starrocks/connector/flink/catalog/StarRocksCatalog.java#L281-L297
2025-02-20 11:14:24,606 INFO com.starrocks.connector.flink.catalog.StarRocksCatalog [] - Success to create table db_test.db_test, sql: CREATE TABLE IF NOT EXISTS `db_test`.`xxxxx` (
`id` BIGINT NOT NULL,
`xxxxx` VARCHAR(192) NOT NULL DEFAULT ""
) PRIMARY KEY (`id`)
DISTRIBUTED BY HASH (`id`);
Metadata
Metadata
Assignees
Labels
No labels