Flink CDC中这是什么原因？
Flink CDC中这是什么原因？
版权声明：本文内容由阿里云实名注册用户自发贡献，版权归原作者所有，阿里云开发者社区不拥有其著作权，亦不承担相应法律责任。具体规则请查看《阿里云开发者社区用户服务协议》和《阿里云开发者社区知识产权保护指引》。如果您发现本社区中有涉嫌抄袭的内容，填写侵权投诉表单进行举报，一经查实，本社区将立刻删除涉嫌侵权内容。
-
北京阿里云ACE会长
根据提供的日志片段，很难准确确定问题的根本原因。但是，有一些可能的原因和建议可以帮助您解决问题：
异常堆栈跟踪中的错误信息 "java.lang.NoSuchMethodError: org.apache.flink.streaming.api.environment.CheckpointConfig.setCheckpointStorage(Ljava/lang/String;)" 表明在您的代码中使用了不兼容的 Flink 版本或相关库的版本。这可能是由于 Flink CDC 和您使用的 Flink 版本不兼容引起的。请确保使用与 Flink CDC 兼容的 Flink 版本，并检查您的依赖项是否正确配置。
请确保 Flink CDC 的版本与您正在使用的 Flink 版本匹配，并且将正确的 Flink CDC 连接器配置为您的 Flink 作业。
检查您的 Flink 作业代码，特别是与 Checkpoint 相关的部分。确保您正确设置了 Checkpoint 相关的配置，例如检查点间隔、检查点存储位置等。
如果您使用了自定义的类或依赖项，确保它们与您所使用的 Flink 版本兼容。
检查您的 Flink 环境和配置是否正确设置。确保正确指定了任务管理器的数量、并行度等配置。
2023-08-11 17:19:05赞同 展开评论
实时计算Flink版是阿里云提供的全托管Serverless Flink云服务，基于 Apache Flink 构建的企业级、高性能实时大数据处理系统。提供全托管版 Flink 集群和引擎，提高作业开发运维效率。