全部面试刷题微服务数据库消息队列搜索引擎大数据运维 go语言机器学习

Flink任务运行的时候报错了：Hadoop is not in the classpath/dependencies.

提问者：帅平问题分类：大数据

Flink任务运行的时候报错了，报错信息如下：

Caused by: org.apache.flink.core.fs.UnsupportedFileSystemSchemeException: Hadoop is not in the classpath/dependencies.
	at org.apache.flink.core.fs.UnsupportedSchemeFactory.create(UnsupportedSchemeFactory.java:55)
	at org.apache.flink.core.fs.FileSystem.getUnguardedFileSystem(FileSystem.java:526)
	... 53 more

Flink Hadoop

发布于：9个月前 (08-03) IP属地：四川省

1 个回答

丢了爱情

这是由于flink程序中使用到了hadoop相关的模块，需要在maven中添加hadoop-client的依赖即可：

<dependency>
			<groupId>org.apache.hadoop</groupId>
			<artifactId>hadoop-client</artifactId>
			<version>3.3.5</version>
		</dependency>

版本的话，根据自己的hadoop版本选择即可。

https://mvnrepository.com/artifact/org.apache.hadoop/hadoop-client

发布于：9个月前 (08-03) IP属地：未知

我来回答