根据文档https://ci.apache.org/projects/flink/flink-docs-release-1.10/dev/table/streaming/joins.html#join-with-a-temporal-table,
临时表table source 必须要继承LookupableTableSource,
但是,看到https://ci.apache.org/projects/flink/flink-docs-release-1.10/dev/table/connect.html#jdbc-connector


-- lookup options, optional, used in temporary 
join'connector.lookup.cache.max-rows'='5000',-- optional, max number of rows of 
lookup cache, over this value, the oldest rows will-- be eliminated. 
"cache.max-rows" and "cache.ttl" options must all be specified if any-- of them 
is specified. Cache is not enabled as 
default.'connector.lookup.cache.ttl'='10s',-- optional, the max time to live 
for each rows in lookup cache, over this time, the oldest rows-- will be 
expired. "cache.max-rows" and "cache.ttl" options must all be specified if any 
of-- them is specified. Cache is not enabled as 
default.'connector.lookup.max-retries'='3',-- optional, max retry times if 
lookup database failed


是不是说在flink sql JDBC Connector DDL中,加上这三个配置项,那么创建的表就是Temporal Table,可以在temporary 
join 中使用?



回复