问题一：Flink CDC里我是想自动做断点续传，比如我某个任务的容器crash了，我需要重启任务怎么办？
Flink CDC里我是想自动做断点续传，比如我某个任务的容器crash了，我需要重启任务，这个时候没法预知去手动savepoint，该如何处理呢？
参考答案：
如果是mysql的话最好是 自己指定下 最新的 log bin.文件的位置，让从指定 位置同步，目前 savepoint还不行。 
建议你找个开发平台去做，你的checkpoint就需要持久化保存，然后去找最近一个成功的checkpoint点去启动。
关于本问题的更多回答可点击进行查看：
https://developer.aliyun.com/ask/592315
问题二：Flink CDCOraclecdc JdbcIncrementalSource 为啥捕获不到数据？
Flink CDC里Oraclecdc JdbcIncrementalSource 捕获不到数据也不报错，什么情况，如何定位问题？ Oracle日志也没报错怎么回事？ 
参考答案：
如果Flink CDC的Oraclecdc JdbcIncrementalSource捕获不到数据也不报错，可能是以下原因：
- 检查数据库连接是否正常，可以尝试使用其他工具连接数据库，确认连接是否成功。
- 检查JdbcIncrementalSource的配置是否正确，特别是表名和字段名是否正确。
- 检查Flink任务的并行度是否设置正确，如果并行度设置过高，可能会导致数据无法正常消费。
- 检查Flink任务的checkpoint是否配置正确，如果checkpoint配置不正确，可能会导致数据无法正常消费。
- 检查Oracle数据库的日志，查看是否有异常或错误信息。
如果以上方法都无法解决问题，可以联系Flink社区或Oracle技术支持寻求帮助。
关于本问题的更多回答可点击进行查看：
https://developer.aliyun.com/ask/592314
问题三：Flink CDC里每次重新启动任务它都会新建的话如何保证断点续传呢？
Flink CDC里我的flink任务每次启动都会在我给的checkpoint目录下面用随机字符串建立子目录，这样我每次重新启动任务它都会新建的话如何保证断点续传呢？ 
我是通过FlinkDeployment部署到云上，启动的时候我尝试这样加过参数，但是貌似起不了作用，可能因为我这个目录是checkpoint自动生成的，不是我手动savepoint的？ 
参考答案：
checkpoint是系统做的，系统出错重试的时候，自己会去找checkpoint目录的检查点，默认是不持久化的
savepoint是手动做的，配合job的迭代使用。
关于本问题的更多回答可点击进行查看：
https://developer.aliyun.com/ask/592313
问题四：Flink CDC里为什么我在用flinkcdc3同步mysql到doris的时候语句不同步？
Flink CDC里为什么我在用flinkcdc3同步mysql到doris的时候,delete语句无法同步呢？ 
参考答案：
在使用 Flink CDC (Continuous Data Capture) 从 MySQL 同步数据到 Doris 时，如果 delete 语句无法同步，可能的原因有以下几点：
- CDC Source端处理：
- 不支持Delete事件捕获：早期版本的Flink CDC可能只支持插入（INSERT）和更新（UPDATE）事件的捕获，而不支持删除事件。但Flink CDC v2.x版本集成了Debezium等工具，理论上应该能够捕获MySQL的DELETE操作。
- 配置问题：
- 确保在配置Flink CDC连接MySQL作为数据源时，启用了binlog格式为ROW，并且设置正确以捕获所有DML操作（包括DELETE）。
- Schema映射与转换：
- 在将变更数据流转换并写入Doris之前，检查数据转换逻辑是否正确处理了DELETE事件。例如，如果只是简单地将变更事件应用到目标表，而没有实现对Doris的相应DELETE操作，那么删除事件就不会被正确反映。
- Doris Sink端处理：
- Doris sink connector在接收到DELETE事件后，需要能够正确地执行相应的删除操作。确认所使用的Doris sink插件或者自定义的sink逻辑是否完整实现了对DELETE事件的支持。
- 事务和一致性保证：
- 考虑到分布式系统的一致性问题，确保在Flink作业中的事务边界设置合理，能正确处理MySQL的删除事务。
关于本问题的更多回答可点击进行查看：
https://developer.aliyun.com/ask/592407
问题五：Flink CDC里StarRocks是否支持oracle的外部表？怎么创建？添加到fe或be？
Flink CDC里StarRocks是否支持oracle的外部表？怎么创建？添加到fe嘛 还是be？
参考答案：
支持。
关于本问题的更多回答可点击进行查看：
