想请问下大家，有遇到 使用 Flink SQL 把Kafka 数据写入Hive 时，报的这个错误吗？
想请问下大家，有遇到 使用 Flink SQL 把Kafka 数据写入Hive 时，报的这个错误吗？
用的的Flink 1.14.5版本，网上是说 flink-connector-hive_2.12 的 guava 包冲突。用IDEA的maven help 插件把相关的冲突都排出了，还是报错
写回答
-
使用 Flink SQL 把 Kafka 数据写入 Hive 时，如果报错如下：
java.lang.ClassNotFoundException: org.apache.flink.api.java.io.jdbc.JdbcOutput
那么可能是 Flink 的版本不支持 Hive 表的写入。Flink 1.15 版本开始支持 Hive 表的写入，如果使用的 Flink 版本低于 1.15，则需要升级 Flink 版本。
如果升级 Flink 版本不方便，也可以使用 Flink SQL Connector 来连接 Hive 表。
Flink SQL Connector 是 Flink 的一款第三方组件，它可以通过 SQL 语句操作 Hive 表。
Flink SQL Connector 的使用方法可以参考 Flink SQL Connector 文档。
2023-09-27 09:39:39赞同 展开评论 打赏
版权声明：本文内容由阿里云实名注册用户自发贡献，版权归原作者所有，阿里云开发者社区不拥有其著作权，亦不承担相应法律责任。具体规则请查看《阿里云开发者社区用户服务协议》和《阿里云开发者社区知识产权保护指引》。如果您发现本社区中有涉嫌抄袭的内容，填写侵权投诉表单进行举报，一经查实，本社区将立刻删除涉嫌侵权内容。
实时计算Flink版是阿里云提供的全托管Serverless Flink云服务，基于 Apache Flink 构建的企业级、高性能实时大数据处理系统。提供全托管版 Flink 集群和引擎，提高作业开发运维效率。
热门讨论
热门文章
相关文章
相关电子书
更多
