问题一：Flink CDC里我部署的flink-cdc任务抓取全量的mysql数据，不生效怎么办？
Flink CDC里我部署的flink-cdc任务抓取全量的mysql数据，checkpoint目前是持久化到oss上，我希望每次重启任务的时候不要从头开始抓取所有的消息。我的想法是在任务里面直接获取oss上最新进度的checkpoint目录，然后通过SavepointRestoreSettings去恢复任务进度，但是不生效。请问是什么情况，或者有没有别的更好解决方案？ 
参考回答：
等3.1发版， 目前 不支持 从savapoint恢复。
关于本问题的更多回答可点击原文查看：https://developer.aliyun.com/ask/592302
问题二：Flink CDC里flink监控你们都是怎么做的？
Flink CDC里flink监控你们都是怎么做的？
参考回答：
自己抓rest api，再转储别的。
关于本问题的更多回答可点击原文查看：https://developer.aliyun.com/ask/592303
问题三：Flink CDC里flink把指标发到influxdb呢？然后自己写代码拉指标发钉钉报警怎么样？
Flink CDC里flink把指标发到influxdb呢？然后自己写代码拉指标发钉钉报警怎么样？ 
参考回答：
Flink CDC本身并不直接提供将指标发送到InfluxDB的功能，但它集成了Flink的Metrics系统，该系统允许你配置自定义的Metrics报告器来导出指标数据到各种外部系统，包括InfluxDB。
要将Flink CDC产生的指标发送到InfluxDB，你需要采取以下步骤：
- 配置Flink Metrics Reporter：
- Flink社区有一些第三方的Metrics Reporter插件，例如
InfluxDBReporter，它可以用来将Flink作业的指标数据发送到InfluxDB。如果没有现成的插件，也可以编写自定义的Metrics Reporter。
- 实现或引入InfluxDB Metrics Reporter：
- 如果已有适用于Flink的InfluxDB Metrics Reporter库，将其添加到项目依赖中。
- 否则，可以根据Flink Metrics API自行实现一个报告器，将指标数据以InfluxDB接受的线协议格式发送到InfluxDB服务。
- 配置Flink作业：
- 在Flink作业的配置中注册并配置InfluxDB Metrics Reporter，包括InfluxDB服务器地址、数据库名、用户名、密码以及其他必要参数。
- 实现报警系统：
- 当数据成功发送到InfluxDB后，你可以利用InfluxDB的查询功能结合Telegraf、Grafana等工具进行实时监控和预警。
- 如果希望直接对接钉钉进行报警，可以编写自定义的报警脚本或者使用钉钉的Webhook机器人服务。通过定时或触发式查询InfluxDB中存储的Flink CDC指标数据，一旦检测到异常阈值触发条件，就向钉钉Webhook发送报警消息。
这样，你就可以搭建一套完整的Flink CDC监控报警系统，其中Flink CDC作业的指标数据会被发送到InfluxDB进行存储和可视化，同时配合自定义的报警机制将重要事件及时推送到钉钉群聊或个人消息中。
关于本问题的更多回答可点击原文查看：https://developer.aliyun.com/ask/592305
问题四：Flink CDC里这种情况是什么原因？
Flink CDC里flink sql通过connector读取mongo数据->写入upsert-kafka后，再用upsert-kafka connector作为source端读取数据->写入doris后，发现会丢失部分数据。另外尝试source端使用普通kafka connector读取数据->写入到doris 数据则是完整的，请问这大概是什么原因？
参考回答：
很难直接定位，多了kafka，就从upsert-kafka这里排查吧。
关于本问题的更多回答可点击原文查看：https://developer.aliyun.com/ask/592307
问题五：Flink CDC里什么时候整个添加内置函数的教学？
Flink CDC里什么时候整个添加内置函数的教学？
参考回答：
Flink CDC（Change Data Capture）是一种用于捕获数据库变更的技术，它能够实时地监控数据库的变化并将这些变化数据同步到下游系统。至于内置函数的添加时间，并没有具体的时间表或发布日期公开。通常，随着Flink版本更新，会不断地有新的功能和内置函数被添加进来，以增强其处理能力和易用性。
如果您想了解Flink CDC中特定内置函数的添加时间，建议查看Flink的官方文档或者跟踪其版本更新日志，这些通常会包含新功能的引入信息。同时，您也可以关注Flink社区的讨论和发布公告，以获取最新的功能更新动态
关于本问题的更多回答可点击原文查看：https://developer.aliyun.com/ask/592309
