社区最近重新设计了 mysql-cdc 的实现,可以支持全量阶段并发读取、checkpoint,移除全局锁依赖。 可以关注 GitHub 仓库的动态 https://github.com/ververica/flink-cdc-connectors。 7月的 meetup 上也会分享相关设计和实现,敬请期待。
Best, Jark On Thu, 17 Jun 2021 at 09:34, casel.chen <[email protected]> wrote: > Flink CDC什么时候能够支持修改并行度,进行细粒度的资源控制?目前我也遇到flink sql > cdc写mysql遇到数据同步跟不上数据写入速度问题,何时能支持像mysql并行复制这种机制呢? > > > > > > > > > > > > > > > > > > 在 2021-06-16 17:27:14,"Leonard Xu" <[email protected]> 写道: > >看起来和 Flink-CDC 关系不大,看异常栈是 ES 侧抛出的异常 version_conflict_engine_exception, > 可以查下这个异常,看下是不是有写(其他作业/业务 也在写同步表)冲突。 > > > >祝好, > >Leonard > > > >> 在 2021年6月16日,17:05,mokaful <[email protected]> 写道: > >> > >> 相同问题,请问有处理方式吗 > >> > >> > >> > >> -- > >> Sent from: http://apache-flink.147419.n8.nabble.com/ >
