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 >issue[1]时在这个issue里一起修复的

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上得不同操作顺序执行的。 To

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

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

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

2020-09-14 文章 Jark Wu
Hi, 这个是我们在实现新版 JDBC sink 的时候发现的问题，所以新版中修复了这个问题。 由于旧版 JDBC 修复起来比较麻烦，可能导致不兼容，且旧版在不久的将来会移除，所以目前没有去修复。 Best, Jark On Mon, 14 Sep 2020 at 11:38, LittleFall <1578166...@qq.com> wrote: > Flink 版本： > flink:1.11.1-scala_2.12 > 连接器 > mysql-connector-java-8.0.21 > flink-sql-connector-kafka_2.12-1.11.1 > f

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',