我理解这个是calcite的机制导致的。calcite并不知道Flink一共有多少层schema,其实Flink
自己抽象了三层,也就是catalog.database.table
但是配置CalciteCatalogReader的时候,需要配置一些默认的schema查找规则,这个Flink是配置了两个,
也就是默认的catalog 和 默认的catalog+默认的database
然后calcite在查找的时候会先尝试default_catalog.default_database作为schema,去查找a.b,此时会先把a当做table去查找,并且找不到。
Hi all,
今天在调试1.11 Flink 代码的时候,发现一个没太理解的现象
考虑以下code
bsTableEnv.executeSql("create database a")
bsTableEnv.executeSql( " CREATE TABLE a.b "(后略))
bsTableEnv.executeSql("select * from a.b")
然后发现了以下现象:
[cid:5272e061-1d69-4e6a-b23b-fe09be09ade4]