如果Flink CDC的Oraclecdc JdbcIncrementalSource捕获不到数据也不报错,可能是以下原因:
检查数据库连接是否正常,可以尝试使用其他工具连接数据库,确认连接是否成功。
检查JdbcIncrementalSource的配置是否正确,特别是表名和字段名是否正确。
检查Flink任务的并行度是否设置正确,如果并行度设置过高,可能会导致数据无法正常消费。
检查Flink任务的checkpoint是否配置正确,如果checkpoint配置不正确,可能会导致数据无法正常消费。
检查Oracle数据库的日志,查看是否有异常或错误信息。
如果以上方法都无法解决问题,可以联系Flink社区或Oracle技术支持寻求帮助。
Flink CDC(Change Data Capture)是一种用于捕获数据库变更的技术,它能够实时地监控数据库的变化并将这些变化数据同步到下游系统。至于内置函数的添加时间,并没有具体的时间表或发布日期公开。通常,随着Flink版本更新,会不断地有新的功能和内置函数被添加进来,以增强其处理能力和易用性。
如果您想了解Flink CDC中特定内置函数的添加时间,建议查看Flink的官方文档或者跟踪其版本更新日志,这些通常会包含新功能的引入信息。同时,您也可以关注Flink社区的讨论和发布公告,以获取最新的功能更新动态。