apache/amoro

[Bug]: Get table failed in the unified catalog

Closed this issue · 0 comments

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