问题一:Flink CDC把原始库删除了以后重新创建了一个名称相同的库来着消费最新的binlog就没啥事了?
Flink CDC把原始库删除了以后重新创建了一个名称相同的库来着,消费最新的binlog就没啥事了
不过我换一个没有删除的库的时候,数据能够读取到,但是会一直出现这样的报错,会有什么影响吗?
参考回答:
默认全量启动会规避中间的数据格式不对的问题
关于本问题的更多回答可点击原文查看: https://developer.aliyun.com/ask/571754
问题二:Flink CDC指定binlog文件,消费成功过吗?
Flink CDC指定binlog文件,消费成功过吗?一直起不来啊,这个功能好像flinkcdc有序列化问题,想跳过应该怎么操作?
参考回答:
Binlog文件会分割,如果你是从指定时间戳启动的话,还是序列化失败的情况,只能怀疑是中间有ddl变更造成了数据格式不兼容导致的:
1、清空binlog
2、从最新启动(历史数据补一下数据)
关于本问题的更多回答可点击原文查看:https://developer.aliyun.com/ask/571753
问题三:Flink CDC1.18跑在k8s,任务提交上去,几十秒自动cancel了,了解吗?
Flink CDC1.18跑在k8s,任务提交上去,几十秒自动cancel了,flink1.13版本没啥问题,有大佬了解吗?
参考回答:
看下k8s控制台日志的stdout
关于本问题的更多回答可点击原文查看:https://developer.aliyun.com/ask/571750
问题四:Flink CDC flink-sql中表名称包含单引号, 应该如何处理?
Flink CDC flink-sql中表名称包含单引号, 应该如何处理?
参考回答:
在Flink SQL中,如果你的表名称包含单引号,你需要对单引号进行转义。在Flink SQL中,你可以使用反斜杠(\)对单引号进行转义。例如,如果你的表名称为'my_table'
,你可以在Flink SQL中这样写:
SELECT * FROM `\'my_table\'`;
这样,Flink SQL就会正确地识别出你的表名称。
这种转义方式在所有SQL方言中都适用,不仅仅是Flink SQL。
关于本问题的更多回答可点击原文查看:https://developer.aliyun.com/ask/571749
问题五:Flink CDC2.4.1 也有遇到这个问题了,这个有解决办法了么 ?
Flink CDC2.4.1 也有遇到这个问题了,原因是运维那边同步一个新库的数据过来 binlog文件短时间增加了很多 但是新库并没有被监听,正常运行的cdc任务就会failed 然后重启,这个有解决办法了么 ?
参考回答:
目前未查明原因的,等待修复中
关于本问题的更多回答可点击原文查看:https://developer.aliyun.com/ask/571748