问题一:flink 1.16.0没捕获到源mysql表数据的变化,请问又可能是什么原因呢?
flink 1.16.0没捕获到源mysql表数据的变化,请问又可能是什么原因呢?源库的binlog是开启了的
参考回答:
是的,阿里云flink 1.16.0没捕获到源mysql表数据的变化,可能是源库的binlog没有开启,或者没有正确配置。
关于本问题的更多回答可点击原文查看:https://developer.aliyun.com/ask/483410?spm=a2c6h.14164896.0.0.60fcd9df1YFUTg
问题二:Flink源表物理表数据删除有什么影响
Flink源表物理表数据删除有什么影响
参考回答:
源表物理表数据被删除后,是不会对任务的正常运行造成影响的,这个需要看任务的下游sink是否支持更新撤回,当不支持更新撤回的时候,上游删除数据,下游是不会生效的,如果支持更新撤回,下游也会将同一条数据给撤回掉。
关于本问题的更多回答可点击原文查看:https://developer.aliyun.com/ask/475375?spm=a2c6h.14164896.0.0.60fcd9df1YFUTg
问题三:flink任务,连接多个 kafka的 topic作为数据源,报类型转换异常。为什么?
flink任务,连接多个 kafka的 topic作为数据源,报类型转换异常。会把第二个 kafka的类型转换成第一个kafka的类型,有大佬知道为啥吗
参考回答:
GitHub https://github.com/co63oc/cloud
查看错误信息
关于本问题的更多回答可点击原文查看:https://developer.aliyun.com/ask/481683?spm=a2c6h.14164896.0.0.60fcd9df1YFUTg
问题四:请问flink sql-client.sh界面中写的源和目标sql是基于binglog捕获数据变更的吗
请问flink sql-client.sh界面中写的源和目标sql是基于binglog捕获数据变更的吗
参考回答:
GitHub https://github.com/co63oc/cloud
是基于binlog捕获变更
关于本问题的更多回答可点击原文查看:https://developer.aliyun.com/ask/479422?spm=a2c6h.14164896.0.0.60fcd9df1YFUTg
问题五:一个flink job里面可以放多个flink cdc数据源吗?能放的话怎么放啊
求助一下一个flink job里面可以放多个flink cdc数据源吗?能放的话怎么放啊
参考回答:
可以的,用多个datasource去接,给每个datasource分配sink,和单个一样的
关于本问题的更多回答可点击原文查看:https://developer.aliyun.com/ask/457567?spm=a2c6h.14164896.0.0.1bf2d9dfeERj61