Re: 请教三张以上时态表关联,加where条件后报错 mismatched type $6 TIMESTAMP(3)的问题

2022-02-06 文章 Caizhi Weng
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

请教三张以上时态表关联,加where条件后报错 mismatched type $6 TIMESTAMP(3)的问题

2022-02-05 文章 liangjinghong
你好,因业务需求,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