Hi Ran:
非常感谢,我试了insert into ON DUPLICATE KEY UPDATE
dt=“dt"的方式,确实是会出现update的始终是id=1,但是auto_increment
却一直增加的情况。感觉这样不是很合理,因为随着数据量的增加,迟早会出现数值越界的情形。
原始邮件
发件人: Michael Ran
收件人: user-zh
发送时间: 2020年9月27日(周日) 14:37
主题: Re:Re: Re: Flink SQL撤回流问题
没有传入id,始终是1 ? 那就是第一次insert update 之后,生成的1.后面都是i
没有传入id,始终是1 ? 那就是第一次insert update 之后,生成的1.后面都是insert into
table(dt,num) values(dt,新数量) ON DUPLICATE KEY UPDATE
dt=values(dt)你模拟下这个语句呢,看看id成为1 之后,是不是就不变了
在 2020-09-27 14:32:57,"xiao cai" 写道:
>Hi lec ssmi:
> insert的时候没有指定id,只指定了dt和cnt,因为id在mysql的sink表里是自增的主键,所以flink sql里并没有指定。
> 原始邮件
>发件人: