Re:Re: Flink 1.11.1 JDBC Sink 使用旧版配置 数据丢失

2020-09-28 文章 Michael Ran
有主键吗？ 有的话不会触发delete 才对 在 2020-09-28 15:54:49，"Leonard Xu" 写道： > > >> 在 2020年9月15日，16:52，LittleFall <1578166...@qq.com> 写道： >> >> 谢谢，请问有相关的 issue 链接吗 >> >> >> >> -- >> Sent from: http://apache-flink.147419.n8.nabble.com/ > >To @LItteFall : > >没有对应的issue，因为是在修复changlog

Re: Flink 1.11.1 JDBC Sink 使用旧版配置 数据丢失

2020-09-28 文章 Leonard Xu
> 在 2020年9月15日，16:52，LittleFall <1578166...@qq.com> 写道： > > 谢谢，请问有相关的 issue 链接吗 > > > > -- > Sent from: http://apache-flink.147419.n8.nabble.com/ To @LItteFall : 没有对应的issue，因为是在修复changlog issue[1]时在这个issue里一起修复的，代码可以看下TableBufferReducedStatementExecutor里reduceBuffer保证是对同key上得不同操作顺序执行的。

Re: Flink 1.11.1 JDBC Sink 使用旧版配置 数据丢失

2020-09-15 文章 LittleFall
谢谢，请问有相关的 issue 链接吗 -- Sent from: http://apache-flink.147419.n8.nabble.com/

Flink 1.11.1 JDBC Sink 使用旧版配置 数据丢失

2020-09-13 文章 LittleFall
Flink 版本： flink:1.11.1-scala_2.12 连接器 mysql-connector-java-8.0.21 flink-sql-connector-kafka_2.12-1.11.1 flink-connector-jdbc_2.12-1.11.1 Flink SQL： CREATE TABLE source_user_name ( loan_no int, name varchar, PRIMARY KEY (loan_no) NOT ENFORCED ) WITH ( 'connector' = 'kafka',