使用flink实时写入数据库，并发只能是1，因为同一条记录会出现多次变化，如果并行度加大，就会导致行锁，最后就一直等待？
以下为热心网友提供的参考意见
Flink实时写入数据库并发只能是1，这是因为同一条记录可能会出现多次变化。如果并行度加大，就会导致行锁，最后就一直等待。这主要源于Flink在设计JDBC Sink时，出于性能因素考虑，对写入buffer做了默认值设置。
解决这个问题的一种方法是使用事务来控制并发。例如，可以使用Flink的CDC（Change Data Capture）功能结合Doris的Flink Connector实现从MySQL数据库中监听数据并实时入库到Doris数仓对应的表中。这样，在高并发场景下，Doris的事务处理能力可以保障ACID特性，支撑Flink秒级的数据写入。
以下为热心网友提供的参考意见
这个问题好像任何多并行的写入都会出现，可以试试replace + 时间戳比较 ，此回答整理自钉群“【③群】Apache Flink China社区”
本文来自投稿，不代表新手站长_郑州云淘科技有限公司立场，如若转载，请注明出处：https://www.cnzhanzhang.com/11489.html
![函数计算里FC 3.0 配置自定义域名的JWT没有办法指定生效的路径，http 触发器可以，怎么办？-[阿里云_云淘科技]](https://www.cnzhanzhang.com/wp-content/themes/justnews/themer/assets/images/lazy.png)