Re: Flink SQL 1.11.1 executeSql/SqlUpdate时 SQL validation的一些问题

2020-09-27 文章 Benchao Li
我理解这个是calcite的机制导致的。calcite并不知道Flink一共有多少层schema,其实Flink 自己抽象了三层,也就是catalog.database.table 但是配置CalciteCatalogReader的时候,需要配置一些默认的schema查找规则,这个Flink是配置了两个, 也就是默认的catalog 和 默认的catalog+默认的database 然后calcite在查找的时候会先尝试default_catalog.default_database作为schema,去查找a.b,此时会先把a当做table去查找,并且找不到。

Flink SQL 1.11.1 executeSql/SqlUpdate时 SQL validation的一些问题

2020-09-25 文章 刘首维
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]