使用flink实时写入数据库,并发只能是1,如果并行度加大,就会导致行锁,最后就一直等待?-[阿里云_云淘科技]

使用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

(0)
匿名
上一篇 2023年12月18日
下一篇 2023年12月18日

相关推荐

新手站长从“心”出发,感谢16年您始终不离不弃。