流表: CREATE TABLE flink_doris_source ( reporttime STRING, tenantcode STRING, visitid STRING, orderid STRING, orderdetailid STRING, paymentdetailid STRING, etltype STRING, ptime as proctime() ) WITH ( 'connector' = 'kafka', 'topic' = 'demo', 'properties.bootstrap.servers' = '10.26.255.82:9092', 'properties.group.id' = 'consumer-55', 'format' = 'json', 'scan.startup.mode' = 'latest-offset' );
维表: CREATE TABLE people ( Id
int, Name
String, Sex
tinyint, Birth
timestamp, Etltype
String, PRIMARY KEY (Id) NOT ENFORCED ) WITH ( 'connector' = 'jdbc', 'url' = 'jdbc:mysql://10.26.20.122:3306/test1', 'table-name' = 'people', 'username'='root', 'password'='*******', 'lookup.cache.ttl'='10s', 'lookup.cache.max-rows'='20' );
mysql ddl: CREATE TABLE people
( Id
int(11) NOT NULL AUTO_INCREMENT, Name
varchar(40) NOT NULL, Sex
tinyint(3) unsigned NOT NULL, Birth
datetime DEFAULT NULL, Etltype
varchar(40) NOT NULL, PRIMARY KEY (Id
) ) ENGINE=InnoDB AUTO_INCREMENT=8 DEFAULT CHARSET=utf8mb4
--流维join INSERT INTO flink_doris_sink select a.reporttime,a.tenantcode,a.visitid,a.orderid,a.orderdetailid,a.paymentdetailid,b.Etltype from flink_doris_source a left join people FOR SYSTEM_TIME AS OF a.ptime b on a.tenantcode = b.Name;
维表数据没有带出来,设置的维表ttl也没效果,是语句问题么? flink版本:flink-1.12.0-bin-scala_2.11.tgz mysql:5.7.32 mysql驱动:8.0.22*来自志愿者整理的flink邮件归档
版权声明:本文内容由阿里云实名注册用户自发贡献,版权归原作者所有,阿里云开发者社区不拥有其著作权,亦不承担相应法律责任。具体规则请查看《阿里云开发者社区用户服务协议》和《阿里云开发者社区知识产权保护指引》。如果您发现本社区中有涉嫌抄袭的内容,填写侵权投诉表单进行举报,一经查实,本社区将立刻删除涉嫌侵权内容。