flinksql1.11连接hive:ClassNotFoundException: org.apache.hadoop.fs.PathHandle

classic Classic list List threaded Threaded
2 messages Options
Reply | Threaded
Open this post in threaded view
|

flinksql1.11连接hive:ClassNotFoundException: org.apache.hadoop.fs.PathHandle

Presley
大家好,我在使用flinksql1.11连接hive做计算时,在idea运行会报错Caused by: java.lang.ClassNotFoundException: org.apache.hadoop.fs.PathHandle,这个怎么解决呢?求指教_(:з」∠)_


另:flink1.11的org.apache.flink.table.catalog.hive.HiveCatalog#HiveCatalog(java.lang.String, java.lang.String, java.lang.String, java.lang.String)方法不需要传hadoop配置文件路径,那flinksql程序在idea运行的话flink会去找到本地hadoop安装路径么?那本地hadoop需要如何配置呢才能让flinksql程序能在本地运行呢?
Reply | Threaded
Open this post in threaded view
|

回复:flinksql1.11连接hive:ClassNotFoundException: org.apache.hadoop.fs.PathHandle

Presley
------------------ 原始邮件 ------------------
发件人:                                                                                                                        "Presley"                                                                                    <[hidden email]&gt;;
发送时间:&nbsp;2021年2月22日(星期一) 中午12:38
收件人:&nbsp;"user-zh"<[hidden email]&gt;;

主题:&nbsp;flinksql1.11连接hive:ClassNotFoundException: org.apache.hadoop.fs.PathHandle



大家好,我在使用flinksql1.11连接hive做计算时,在idea运行会报错Caused by: java.lang.ClassNotFoundException: org.apache.hadoop.fs.PathHandle,这个怎么解决呢?求指教_(:з」∠)_


另:flink1.11的org.apache.flink.table.catalog.hive.HiveCatalog#HiveCatalog(java.lang.String, java.lang.String, java.lang.String, java.lang.String)方法不需要传hadoop配置文件路径,那flinksql程序在idea运行的话flink会去找到本地hadoop安装路径么?那本地hadoop需要如何配置呢才能让flinksql程序能在本地运行呢?