向大佬们请教一个问题,FLInk 1.16版本中 维表缓存的用法,目前我这边遇到维表ttl后不会更新数据问题
CREATE TABLE order_device_info_source (
order_id BIGINT,
consume_date TIMESTAMP(0),
upload_date TIMESTAMP(0),
up_status_id INT,
consume_money INT,
project_id BIGINT,
PRIMARY KEY (order_id, consume_date) NOT ENFORCED
) WITH ( 'connector' = 'mysql-cdc', 'server-id' = '5591', 'hostname' = '127.0.0.1:3306', 'port' = '3306', 'username' = 'root', 'password' = '123456', 'database-name' = 'wit_order', 'table-name' = 'order_[0-9]+', 'scan.snapshot.fetch.size' = '5000', 'scan.startup.mode' = 'latest-offset' );
CREATE TEMPORARY TABLE project_info_lookup ( project_id
bigint, project_name
VARCHAR, tenant_id
bigint, PRIMARY KEY (project_id) NOT ENFORCED ) WITH ( 'connector' = 'jdbc', 'driver' = 'com.mysql.cj.jdbc.Driver', 'url' = 'jdbc:mysql://127.0.0.1:3306/project', 'username' = 'root', 'password' = '123456', 'table-name' = 'project_info', 'lookup.cache.max-rows' = '5000', 'lookup.cache.ttl' = '60 s' );
SELECT o.order_id,o.consume_date,o.consume_money,p.project_id,p.project_name LEFT JOIN project_info_lookup AS p ON p.project_id = oa.projectId;单独SELECT project_info_lookup 维表会更新 但是join后 维表 lookup.cache.ttl 好像未生效 ,在project_info发生改变,且lookup.cache.ttl时间过了,project_info_lookup还是以前的数据
版权声明:本文内容由阿里云实名注册用户自发贡献,版权归原作者所有,阿里云开发者社区不拥有其著作权,亦不承担相应法律责任。具体规则请查看《阿里云开发者社区用户服务协议》和《阿里云开发者社区知识产权保护指引》。如果您发现本社区中有涉嫌抄袭的内容,填写侵权投诉表单进行举报,一经查实,本社区将立刻删除涉嫌侵权内容。