问题一:flink cdc 3.0中的源端 mysql中主键id是这个,后续怎么做?
flink cdc 3.0中的源端 mysql中主键id是这个,后续怎么做?
参考回答:
不着急的话等下一个版本吧,着急的话自己改一下源码自己编译一下。
关于本问题的更多回答可点击原文查看:https://developer.aliyun.com/ask/605861
问题二:Flink CDC 里mysql->Doris的整库同步,没有成功自动建表以及同步数据?
Flink CDC 里mysql->Doris的整库同步,没有成功自动建表以及同步数据?
参考回答:
用flink1.17.0把akka.ask.timeout这个参数调至120s 试一下 。你到jobmanager的config中搜索 一下akka.ask.timeout这个参数。link session 需要重启一下这个配置才能生效。另外这个问题已经在修复了。
关于本问题的更多回答可点击原文查看:https://developer.aliyun.com/ask/605858
问题三:Flink CDC 里这种情况怎么解决?
Flink CDC 里这种情况怎么解决?
参考回答:
这种有可能就是这个表的数据很长时间不发生变化 而state中保存当前消费的binlog文件和偏移量 但是这个mysql实例其他的库和表数据变化很快 binlog文件一直在滚动 而binlog文件默认只保留几天的 所以你的state中保存的binlog文件可能就被冲掉了,建议升级到2.3.0。
关于本问题的更多回答可点击原文查看:https://developer.aliyun.com/ask/605853
问题四:flinkcdc从今天开始莫名奇妙的进入假死状态为什么?
flinkcdc从今天开始莫名奇妙的进入假死状态为什么?
参考回答:
用2.3.0及以上的版本吧。
关于本问题的更多回答可点击原文查看:https://developer.aliyun.com/ask/605846
问题五:Flink CDC 里咋个支持yarn呢?
Flink CDC 里咋个支持yarn呢?
参考回答:
修改flink-conf.yaml文件
参数的意义:
rest.port:客户端连接到的端口。如果未指定rest.bind-port,则REST服务器将绑定到该端口。
rest.bind.port:服务器绑定自身的端口。接受端口列表(“ 50100,50101”),范围(“ 50100-50200”)或两者的组合。建议设置一定范围的端口,以防止在同一台计算机上运行多个Rest服务器时发生冲突。
因此,将rest.bind.port端口添加指定的范围即可。
——参考链接。
关于本问题的更多回答可点击原文查看:https://developer.aliyun.com/ask/605839