Flink CDC中这个怎么解决？
Flink CDC中这个怎么解决？
版权声明：本文内容由阿里云实名注册用户自发贡献，版权归原作者所有，阿里云开发者社区不拥有其著作权，亦不承担相应法律责任。具体规则请查看《阿里云开发者社区用户服务协议》和《阿里云开发者社区知识产权保护指引》。如果您发现本社区中有涉嫌抄袭的内容，填写侵权投诉表单进行举报，一经查实，本社区将立刻删除涉嫌侵权内容。
-
我正在尝试使用 Flink CDC 从 PostgreSQL 中读取数据，但是我遇到了以下错误：
Exception in thread "main" java.lang.NoClassDefFoundError: org/apache/calcite/adapter/jdbc/JdbcMeta
我已经将 calcite-core 和 calcite-jdbc 添加到 my classpath 中，但我仍然得到同样的错误。这个问题是由于 Flink CDC 依赖 calcite-core 和 calcite-jdbc 的旧版本，而您使用的版本是较新的版本。解决这个问题的方法是将 calcite-core 和 calcite-jdbc 的版本降低到 Flink CDC 支持的版本。
您可以使用以下命令查看 Flink CDC 支持的 calcite-core 和 calcite-jdbc 的版本：
$ mvn dependency:tree -Dverbose -Dincludes=org.apache.calcite:calcite-core,org.apache.calcite:calcite-jdbc
这个命令会显示 Flink CDC 依赖的所有库及其版本。找到 calcite-core 和 calcite-jdbc 的版本，然后将它们降低到这个版本。如果您不想降低 calcite-core 和 calcite-jdbc 的版本，也可以尝试使用 Flink CDC 的旧版本。
2023-09-22 11:13:06赞同 展开评论
实时计算Flink版是阿里云提供的全托管Serverless Flink云服务，基于 Apache Flink 构建的企业级、高性能实时大数据处理系统。提供全托管版 Flink 集群和引擎，提高作业开发运维效率。