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

Re: Pyflink 1.14 维表 DDL报错

2022-02-06 文章 Caizhi Weng
Hi! 你看的是阿里云 Blink 的文档。Blink 是阿里原来基于 Flink 1.5 开发的产品,所以一些语法与现在的 Flink 有些不同。period for system_time 是以前 blink 定义维表的语法,现在不需要写了。另外 datagen 确实不能作为维表的数据来源,可以尝试用文件作为维表来源,比如 csv 文件。 目前 Blink 的大部分代码已贡献回 Flink(Flink 1.14 默认 planner 就是原来的 Blink planner),建议直接看 Flink 官网的文档学习[1]。 如果想要了解商业化的内容,应该看阿里云 Flink

Pyflink 1.14 ???? DDL????

2022-02-06 文章 ??????
flink??join??join??https://help.aliyun.com/document_detail/62506.html??flink sql?? ddl?? create table phoneNumber( name VARCHAR, phoneNumber bigint, primary key(name), PERIOD FOR SYSTEM_TIME )with(

????

2022-02-06 文章 ????