HADOOP_CLASSPATH 设置了吗？
Zhiwen Sun
On Fri, Jun 18, 2021 at 9:47 AM yangpengyi <963087...@qq.com.invalid> wrote:
> 环境： FLINK 1.12 & CDH6.1.1
> 问题：
>
> 利用yarn-per-job提交时，在初始化hdfs客户端时出错。看起来应该是hadoop版本的兼容问题，不过从堆栈看应该使用到了正确的客户端jar包。
> Caused by: org.apache.flink.core.fs.UnsupportedFileSystemSchemeExc
设置了，从堆栈来看根源是调用client的initialze方法有问题，这里应该是获取到了hadoop classpath中的正确版本的客户端
org.apache.hadoop.hdfs.DistributedFileSystem.initialize(DistributedFileSystem.java:167)~[hadoop-hdfs-client-3.0.0-cdh6.1.1.jar:?]
--
Sent from: http://apache-flink.147419.n8.nabble.com/
