Caused by: java.lang.ClassNotFoundException: org.apache.hadoop.mapred.JobConf
Flink 1.13.0 集成 Hive 的时候,执行报错 Caused by: java.lang.ClassNotFoundException: org.apache.hadoop.mapred.JobConf 解决方法在pom.xml 中添加下面的配置:
<dependency>
<groupId>org.apache.hadoop</groupId>
<artifactId>hadoop-mapreduce-client-core</artifactId>
<version>${hive.version}</version>
</dependency>
<dependency>
<groupId>org.apache.hadoop</groupId>
<artifactId>hadoop-common</artifactId>
<version>${hive.version}</version>
</dependency>
<dependency>
<groupId>org.apache.hadoop</groupId>
<artifactId>hadoop-mapreduce-client-common</artifactId>
<version>${hive.version}</version>
</dependency>
<dependency>
<groupId>org.apache.hadoop</groupId>
<artifactId>hadoop-mapreduce-client-jobclient</artifactId>
<version>${hive.version}</version>
</dependency>
|