ITPub博客

首页 > 大数据 > Hadoop > Flink cdc 读取MySQL,lock table问题

Flink cdc 读取MySQL,lock table问题

原创 Hadoop 作者:元亨利贞 时间:2023-07-30 23:42:26 0 删除 编辑

解决方案:

使用snapshot.locking.mode参数:这个参数可以设置全量阶段的锁模式,有三个可选值:none、minimal和extended。默认值是extended,表示在全量阶段会锁住所有表,不允许其他客户端进行DML操作。如果设置为minimal,表示只锁住正在读取的表,其他表可以正常操作。如果设置为none,表示不锁任何表,但是可能会导致数据不一致。


使用snapshot.new.tables参数:这个参数可以设置增量阶段是否对新表进行快照读取,有三个可选值:off、parallel和sequential。默认值是parallel,表示在增量阶段会对新表进行快照读取,并且会锁住新表。如果设置为off,表示不对新表进行快照读取,也不会锁住新表。如果设置为sequential,表示在增量阶段会对新表进行快照读取,但是不会锁住新表,而是顺序地读取每个新表。


来自 “ ITPUB博客 ” ,链接:https://blog.itpub.net/70024433/viewspace-2967183/ ,如需转载,请注明出处,否则将追究法律责任。

请登录后发表评论 登录
全部评论

注册时间:2022-11-21

  • 博文量
    383
  • 访问量
    247967