Re:Re: Re: Flink SQL撤回流问题

2020-09-27 文章 xiao cai
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

Re:Re: Re: Flink SQL撤回流问题

2020-09-27 文章 Michael Ran
没有传入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里并没有指定。 > 原始邮件 >发件人: