AI 助理
备案控制台

decq全全_个人页

decq全全
个人头像照片
文章
0
问答
1
视频
0

个人介绍

暂无个人介绍

擅长的技术

  • 容器
  • Linux
  • 数据库
获得更多能力
通用技术能力：

暂时未有相关通用技术能力~

云产品技术能力：

阿里云技能认证

详细说明
暂无更多信息

2024年01月

正在加载, 请稍后...
暂无更多信息
  • 回答了问题 2024-01-26

    使用FLink CDC 3.0 ，将MySQL数据同步到SR遇到一些问题

    这个问题是因为任务没有使用 savepoint 重启。因此重启后会再次进行全量同步，此时insert、update 的操作数据都能够读取到最新的结果，而 delete 数据则因源表不再包含这条数据，下游不会做对应处理。数据仍然保存。解决办法是通过 flink savepoint 停止原来的任务，如执行下面命令： flink stop [--savepointPath ] 并且在 flink-conf.yaml 里设置 execution.savepoint.path 指定 savepoint 路径，重新启动 cdc 任务。这样 cdc 任务会从重启前的位点，逐条处理binlog，正确处理 delete 事件。Flink 3.0 还不支持通过 -s/--savepoint 参数指定savepoint 路径。
    踩0 评论0
正在加载, 请稍后...
滑动查看更多
正在加载, 请稍后...
暂无更多信息