Flink 1.10 on yarn提交任务报错

[huangrunxingxing]

./bin/flink run -m yarn-cluster -yn 2 -yjm 1024 -ytm 1024 ./examples/batch/WordCount.jar








java.lang.Exception: unable to establish the security context
        at org.apache.flink.runtime.security.SecurityUtils.install(SecurityUtils.java:73)
        at org.apache.flink.client.cli.CliFrontend.main(CliFrontend.java:964)
Caused by: org.apache.flink.runtime.security.modules.SecurityModule$SecurityInstallException: Unable to set the Hadoop login user
        at org.apache.flink.runtime.security.modules.HadoopModule.install(HadoopModule.java:146)
        at org.apache.flink.runtime.security.SecurityUtils.install(SecurityUtils.java:67)
        ... 1 more
Caused by: java.lang.NoSuchMethodError: org.apache.flink.runtime.util.HadoopUtils.isCredentialsConfigured(Lorg/apache/hadoop/security/UserGroupInformation;Z)Z
        at org.apache.flink.runtime.security.modules.HadoopModule.install(HadoopModule.java:140)
        ... 2 more


| |
huangrunxingxing
|
|
[hidden email]
|
签名由网易邮箱大师定制

[Jacob]

hi，

可以先做如下尝试：

export HADOOP_USER_NAME=your user

export HADOOP_CONF_DIR=your hadoop conf dir

export HADOOP_CLASSPATH=`/opt/app/hadoop/bin/hadoop classpath`



-----
Thanks!
Jacob
--
Sent from: http://apache-flink.147419.n8.nabble.com/