Hi!
你想要将主表和两张维表进行连续的 event time temporal join 吗?
第一个 SQL 语句是不是不完整,只有一个 join on 却有两张表。
第二个 SQL 语句中,首先定义 view 应该通过 create view 语句,其次 event time temporal join
应该使用左表的 event time。你的语句中,第一个 join 使用的是 FOR SYSTEM_TIME AS OF
job.lastUpdateTime 这是正确的,但第二个 join 使用的是 FOR SYSTEM_TIME AS OF
t.lastModifiedTim
你好,因业务需求,flink 1.13,MySQL CDC
2.1.1下需要将三张满足时态表结构的表关联,在没有对关联结果加where条件时,可以正常运行,加了where条件后,报错如下:
SQL:
insert into sink
select count(1) as machine from tbl_schedule_job as job
join tbl_schedule_task FOR SYSTEM_TIME AS OF job.lastUpdateTime as t
on t.jobId = job.jobId FOR SYSTEM_TIME AS OF t.lastModif