问题一:Flink CDC这这么知道是不是日期类型?
Flink CDC这这么知道是不是日期类型?
参考回答:
需要你自己搞的哈,不要用官方的 JsonDebeziumDeserializationSchema
https://ververica.github.io/flink-cdc-connectors/master/content/about.html
这样你就没问题了吧,字段类型你也拥有了
schema里面会有data type ,你判断下然后找下对应字段,取值转一下
关于本问题的更多回答可点击原文查看:https://developer.aliyun.com/ask/572331
问题二:Flink CDC mysql的datetime类型获取出来是个int?
Flink CDC mysql的datetime类型获取出来是个int?
参考回答:
ds都是bigint,对的,ds就是数字类型的,你用sql就不是
你用日期方法转一下就行了
关于本问题的更多回答可点击原文查看:https://developer.aliyun.com/ask/572330
问题三:现在 flink CDC 支持 schema Evolution 了吗?
现在 flink CDC 支持 schema Evolution 了吗?找了下相关 pull request 貌似还没有合并嘛:
https://github.com/ververica/flink-cdc-connectors/pull/2685
参考回答:
wait 3.0
关于本问题的更多回答可点击原文查看:https://developer.aliyun.com/ask/572284
问题四:请问Flink CDC有哪位做过国产数据库达梦的同步吗?
请问Flink CDC有哪位做过国产数据库达梦的同步吗?
参考回答:
目前 Flink CDC 社区还没有针对达梦数据库的官方支持,因此无法直接使用 Flink CDC 进行数据同步。
然而,有些开发者自行实现了 Flink CDC 的扩展插件,可以支持达梦数据库。请注意,这些插件的质量可能会有所差异,并且可能存在一些已知问题。
关于本问题的更多回答可点击原文查看:https://developer.aliyun.com/ask/572328
问题五:Flink CDC我需要设置什么参数 才能增加挖掘的速度 ?
Flink CDC我需要设置什么参数 才能增加挖掘的速度 ?一天24个小时 有几个小时会出现延迟 现在是一次性抽取50多张表
参考回答:
根据表查询数据的sql 是用的 regex function 这块表越多,sql查询性能也比较慢;可以想想多 connection 并发触发 logminer 解析数据,,最后 单线程控制 事件顺序
关于本问题的更多回答可点击原文查看:https://developer.aliyun.com/ask/572326