Search before asking
Fluss version
0.6.0 (latest release)
Please describe the bug 🐞
Minimal reproducible example.
- Spin up containers following the Flink quickstart guide
- Enter the SQL client
docker compose exec jobmanager ./sql-client
- Create catalog
CREATE CATALOG fluss_catalog WITH (
'type' = 'fluss',
'bootstrap.servers' = 'coordinator-server:9123'
);
USE CATALOG fluss_catalog;
- Exit the SQL client.
- Enter the SQL client again.
USE CATALOG fluss_catalog;
throws
[ERROR] Could not execute SQL statement. Reason:
org.apache.flink.table.catalog.exceptions.CatalogException: A catalog with name [fluss_catalog] does not exist.
However, note that when creating tables in a catalog, the tables are correctly assigned.
- Spin up containers following the Flink quickstart guide
- Enter the SQL client
docker compose exec jobmanager ./sql-client
- Create catalog
CREATE CATALOG fluss_catalog WITH (
'type' = 'fluss',
'bootstrap.servers' = 'coordinator-server:9123'
);
USE CATALOG fluss_catalog;
- Create a table in
fluss_catalog
CREATE TABLE fluss_order (
`order_key` BIGINT,
`cust_key` INT NOT NULL,
`total_price` DECIMAL(15, 2),
`order_date` DATE,
`order_priority` STRING,
`clerk` STRING,
`ptime` AS PROCTIME(),
PRIMARY KEY (`order_key`) NOT ENFORCED
);
- Exit the SQL client.
- Enter the SQL client again.
USE CATALOG fluss_catalog;
throws
[ERROR] Could not execute SQL statement. Reason:
org.apache.flink.table.catalog.exceptions.CatalogException: A catalog with name [fluss_catalog] does not exist.
- "Recreate" catalog
CREATE CATALOG fluss_catalog WITH (
'type' = 'fluss',
'bootstrap.servers' = 'coordinator-server:9123'
);
USE CATALOG fluss_catalog;
- Although the client throws the
CatalogException when we do not "recreate" the catalog, the table is there after "recreating" the catalog.
+-----------------+
| table name |
+-----------------+
| fluss_order |
+-----------------+
Solution
No response
Are you willing to submit a PR?
Search before asking
Fluss version
0.6.0 (latest release)
Please describe the bug 🐞
Minimal reproducible example.
docker compose exec jobmanager ./sql-clientthrows
However, note that when creating tables in a catalog, the tables are correctly assigned.
docker compose exec jobmanager ./sql-clientfluss_catalogthrows
CatalogExceptionwhen we do not "recreate" the catalog, the table is there after "recreating" the catalog.Solution
No response
Are you willing to submit a PR?