使用flink cdc以YashanDB作为源库同步数据,update语句中未被update列的值被同步为NULL
flink cdc通过ystream连接到YashanDB,解析event并同步至sink库。
实际使用中,会碰到如下现象。在源库中下发update语句,仅修改test表的一列:
flink cdc和YashanDB ystream在同步update语句时,用的是upsert模式。
如果在开启附加日志时没有指定all columns,那么未被更新列的值就不会被同步至目标库,其值被错误同步为null。
在YashanDB侧开启附加日志时,仅指定了primary key:
ALTER TABLE TEST ADD SUPPLEMENTAL LOG DATA (PRIMARY KEY) COLUMNS;
ALTER TABLE TEST ADD SUPPLEMENTAL LOG DATA (ALL) COLUMNS;
ꄘ浏览量:0
友情链接:深圳计算科学研究院 深圳崖山科技有限公司
版权所有© 深圳崖山科技有限公司 粤ICP备2022018810号
公众号
加入技术交流群
YashanDB
崖山数据库系统YashanDB是深圳计算科学研究院自主设计研发的新型数据库管理系统,融入原创的有界计算、近似计算、并行可扩展和跨模融合计算理论,可满足金融、政企、能源等关键行业对高性能、高并发及高安全性的要求。
邮箱:info@yashandb.com
地址:广东省深圳市龙华区民宝路红山6979园区25座5-10层