org.apache.flink.client.program.ProgramInvocationException: The main method caused an error: Failed

org.apache.flink.client.program.ProgramInvocationException: The main method caused an error: Failed,第1张

在idea上执行flinkCDC是正常的,结果到了Linux上报异常:

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:528)

原因:我的1.14.4版本的Flink没有Hadoop集成,因此无法直接 *** 作HDFS

下载相关jar包

https://repo.maven.apache.org/maven2/org/apache/flink/flink-shaded-hadoop-2-uber/2.7.5-7.0/flink-shaded-hadoop-2-uber-2.7.5-7.0.jar

上传到flink/lib下

重启flink

ok,任务提交成功

欢迎分享,转载请注明来源:内存溢出

原文地址: http://outofmemory.cn/langs/871669.html

(0)
打赏 微信扫一扫 微信扫一扫 支付宝扫一扫 支付宝扫一扫
上一篇 2022-05-13
下一篇 2022-05-13

发表评论

登录后才能评论

评论列表(0条)

保存