INFO-更换cdc插件操作流程

适用模块
实时传输
具体说明
传输手动更换插件包
使用示例
确认当前版本

INFO-更换cdc插件操作流程 - 图1

把包放在包服务器地址下的 flink_plugin目录下 INFO-更换cdc插件操作流程 - 图2

注意:md5文件没有的话 命令:md5sum xxx.tar.gz > xxx.tar.gz.md5 生成一个到当前路径 否则升级会失败

增加flink_plugin cdc插件新版本 版本名称不确认可以参考上面当前版本向后迭代写入 INFO-更换cdc插件操作流程 - 图3

INFO-更换cdc插件操作流程 - 图4

INFO-更换cdc插件操作流程 - 图5

成功后包服务器上可以下载一个历史升级模板,或者复用下面这个
INFO-更换cdc插件操作流程 - 图6

更换开发提供包中对应的 targetVersion 对应的value值,对应文件放入升级即可

INFO-更换cdc插件操作流程 - 图7

最后一定要 下发sloth submmiter 否则会爆插件不存在的错误

INFO-更换cdc插件操作流程 - 图8

INFO-更换cdc插件操作流程 - 图9


作者:华柄印