可以复现,如果你现在对主键字段进行变更,是可以传下去的,他把update变成了delete+insert的方式。
然后第一次的时候传下去应该也是因为CDC报错重启,自动更改了一下safe-mode=true,然后把update变为了delete+replace,导致传下去一条,然后又转回了默认值,safe-mode=false,默认值下不进行主键变更,update就是传下去update,所以没有进行更新数据。
在sink-uri里面,指定上safe-mode=true后,应该就可以了。
可以复现,如果你现在对主键字段进行变更,是可以传下去的,他把update变成了delete+insert的方式。
然后第一次的时候传下去应该也是因为CDC报错重启,自动更改了一下safe-mode=true,然后把update变为了delete+replace,导致传下去一条,然后又转回了默认值,safe-mode=false,默认值下不进行主键变更,update就是传下去update,所以没有进行更新数据。
在sink-uri里面,指定上safe-mode=true后,应该就可以了。