[Bug]: Get table failed in the unified catalog
Closed this issue · 0 comments
YesOrNo828 commented
What happened?
See how to reproduce.
Affects Versions
master
What engines are you seeing the problem on?
No response
How to reproduce
Executing the statements in the Flink SQL Client:
CREATE CATALOG unified_catalog WITH ('type'='unified', 'metastore.url'='...');
use catalog unified_catalog;
create catalog mem_catalog with('type'='generic_in_memory');
create table mem_catalog.`default`.datagen_table( a int, b varchar) with( 'connector'='datagen', 'number-of-rows'='1'");
select * from mem_catalog.`default`.datagen_table;
Executing the query statement would occur the exception:
Caused by: com.netease.arctic.NoSuchTableException: Table: mem_catalog does not exist.
at com.netease.arctic.CommonUnifiedCatalog.lambda$loadTable$2(CommonUnifiedCatalog.java:124)
at java.util.Optional.orElseThrow(Optional.java:290)
at com.netease.arctic.CommonUnifiedCatalog.loadTable(CommonUnifiedCatalog.java:124)
at com.netease.arctic.flink.catalog.FlinkUnifiedCatalog.getTable(FlinkUnifiedCatalog.java:173)
Relevant log output
No response
Anything else
No response
Are you willing to submit a PR?
- Yes I am willing to submit a PR!
Code of Conduct
- I agree to follow this project's Code of Conduct