Flink有没有人用过JDBC连接器sink的时候删除数据?

Flink有没有人用过JDBC连接器sink的时候删除数据,我找了半天没看到有指定op的参数,JDBC连接器实时同步的时候支持删除数据吗?

flink JDBC SQL sink到mysql表Duplicate entry问题

flink JDBC SQL Connector sink到mysql表,mysql表有主键和唯一键,定义sink mysql 表唯一键为主键,任务报Caused by: java.sql.SQLIntegrityConstraintViolationException: Duplicate ent...

JDBC数据库开发入门

15 课时 |
1906 人已学 |
免费

JDBC数据库开发进阶

22 课时 |
1185 人已学 |
免费
开发者课程背景图

请教各位老师 Flink CDC中 jdbc sink ck 时,是jar 包的事吗?老师

问题1:请教各位老师 Flink CDC中 jdbc sink ck 时 是jar 包的事吗 老师 问题2:2.4版本支持clickhouse吗

请问有没有人遇到过使用MySQL CDC,然后Flink jdbc写Oracle sink, 因为写

请问有没有人遇到过使用MySQL CDC,然后Flink jdbc写Oracle sink, 因为写入出错(Oracle报错)不断重试,导致Oracle连接被耗完?

在使用flink cdc 通过jdbc sink到MySQL时,报了下面的错误,请问怎么解决?

在使用flink cdc 通过jdbc sink到MySQL时,报了下面的错误请问怎么解决:目标库mysql:5.7.19flink cdc: 2.2.1flink:1.14.4mysql-jdbc:5.1.xflink-connector-jdbc:2.12-1.14.4

jdbc_2.12-1.14.4 sink支持回撤流吗?似乎flink sql中-D的数据并不能执行

jdbc_2.12-1.14.4 sink支持回撤流吗?似乎flink sql中-D的数据并不能执行

,jdbc sink支持回撤流吗?似乎flink sql中-D的数据并不能执行删除的mysql的对应

,jdbc sink支持回撤流吗?似乎flink sql中-D的数据并不能执行删除的mysql的对应数据

请问flink-connector-jdbc在sink时,如何设置批量写入?

尝试了sink.buffer-flush.max-rows,感觉没生效。

jdbc.exactlyoncesink两个sink往同一个MySQL表更新数据,出现事务锁怎么解决

用jdbc.exactlyoncesink两个sink往同一个MySQL表更新数据,出现事务锁怎么解决

建sink表时,jdbc url这样写报错,这样的格式对吗?

建sink表时,jdbc url这样写报错,这样的格式对吗?

本页面内关键词为智能算法引擎基于机器学习所生成,如有任何问题,可在页面下方点击"联系我们"与我们沟通。