Flink CDC这个问题怎么解决？他只认启动的那一刻的所有表。
Flink CDC这个问题怎么解决？他只认启动的那一刻的所有表。
版权声明：本文内容由阿里云实名注册用户自发贡献，版权归原作者所有，阿里云开发者社区不拥有其著作权，亦不承担相应法律责任。具体规则请查看《阿里云开发者社区用户服务协议》和《阿里云开发者社区知识产权保护指引》。如果您发现本社区中有涉嫌抄袭的内容，填写侵权投诉表单进行举报，一经查实，本社区将立刻删除涉嫌侵权内容。
-
北京阿里云ACE会长
可能的原因和解决方法：
CDC Connector 配置问题：首先，你需要检查 Flink CDC Connector 的配置是否正确。确保正确配置了数据库连接参数、表名称、主题等信息。例如，检查是否提供了正确的数据库连接字符串、用户名和密码等。
数据库访问权限问题：确保 Flink CDC 连接器具有足够的权限来访问数据库和表。验证连接器使用的数据库用户具有正确的权限，包括读取表结构、捕获变更等。
CDC Connector 版本与 Flink 版本兼容性：确保使用的 Flink CDC Connector 版本与你正在使用的 Flink 版本兼容。检查 Flink 和 CDC Connector 的版本兼容性矩阵，并使用兼容的版本。
CDC Connector 的稳定性问题：某些版本的 CDC Connector 可能存在稳定性问题，可能会导致意外的中断或错误。尝试升级到最新版本的 CDC Connector，以解决已知的问题和错误。
日志级别和日志输出：调整日志级别，以便获取更详细的错误信息和上下文。确保正确配置了日志输出路径和格式，以便更好地调试和排查问题。
2023-08-13 17:12:11赞同 展开评论 -
意中人就是我呀！
启动当时scheme informmation固定了，你可以savepoint后再启动，不过这个配合动态加表的功能一起使用，否则状态不兼容是有问题的。配的*，每次库里新增表，都得重启任务。每次库里新增表是少数的情况。此回答整理至钉群“Flink CDC 社区”。
2023-08-09 11:56:21赞同 展开评论
实时计算Flink版是阿里云提供的全托管Serverless Flink云服务，基于 Apache Flink 构建的企业级、高性能实时大数据处理系统。提供全托管版 Flink 集群和引擎，提高作业开发运维效率。