问答 请问下chunjun的问题,mysql-sink端,只接收insert\update是吗?delete不支持是吗?

请问下chunjun的问题,mysql-sink端,只接收insert\update是吗?delete不支持是吗?

   匿名用户    发布于 2022-12-06 13:52 最新回复 2022-12-06 13:53  来自于   群内解答  84  1

请问下,mysql-sink端,只接收insert\update是吗?delete不支持是吗?

需要怎么配置呢?

我目前的配置是这样子的

CREATE TABLE test_sink
(
id int,
cname varchar,
sale_amt decimal(16,2),
ttime timestamp,
PRIMARY KEY (id) NOT ENFORCED
)WITH (
'connector' = 'mysql-x',
'username' = 'root',
'password' = '1906281b',
'url' = 'jdbc:mysql://172.16.44.83:3306/ambari',
'table-name' = 'test_sink',
'sink.all-replace' = 'true',
'sink.parallelism' = '1'
);  


{"before":{"id":5,"cname":"waryas","sale_amt":50.2,"ttime":"2022-12-06 10:27:19"},"after":null,"op":"d"} 

1条回答
群内解答
回复于 2022-12-06 13:53

正常是可以使用

delete  的


想了解或咨询更多有关袋鼠云大数据产品、行业解决方案、客户案例的朋友,浏览袋鼠云官网:https://www.dtstack.com/?src=bbs

同时,欢迎对大数据开源项目有兴趣的同学加入「袋鼠云开源框架钉钉技术群」,交流最新开源技术信息,群号码:30537511,项目地址:https://github.com/DTStack/chunjun

0 0
社区公告
  • 大数据领域最专业的产品&技术交流社区,专注于探讨与分享大数据领域有趣又火热的信息,专业又专注的数据人园地

最新活动更多
微信扫码获取数字化转型资料
钉钉扫码加入技术交流群