Hi！
我观察到 flink 双流 join ttl 处理的一些现象，望解答：
kafka 中存有 students，courses 两个 topic 作为输入流，表结构如下：
students s：id，name
courses c：stu_id，name，score
两条流通过 s.id = c.stu_id 关联，ttl 设置的过期时间为 2min
测试sql：
SELECT s.id, s.name, c.course, c.score FROM student AS s LEFT JOIN
courses AS c ON s.id = c.stu_id
测试现象：
ttl
需要建立mysql表request_date,terminal_no的联合主键，mysql的upsert是基于"INSERT INTO ... ON
DUPLICATE KEY UPDATE..."实现的。
ddl中可以不声明mysql主健。
鱼子酱 <384939...@qq.com>于2020年11月17日 周二09:13写道：
> 我写的是upsert呀。。。
> insert into 我也测试了，也不行。
>
> 是MySQL数据库本身里面的表需要建立一个主键吗？还是只有flink里面建表的时候写就行呢？
>
>
>
> --
> Sent from:
请教一下，我在用flink-sql-gateway的1.11.1版本的SET语法设置hive dialect时（SET
table.sql-dialect=hive），flink-sql-gateway出现了报错，同样的语法在sql-client是支持的，那如果我想在session级切换hive
dialect我应该怎么做呢? 多谢
我的环境如下：
flink-sql-gateway:1.11.1
flink:1.11.1
hive:3.1.2
hadoop:3.0.0
日志如下：
2020-08-31 20:39:56,051 INFO
