环境
Flink-1.4.2
hadoop 2.6.0-cdh5.13.0,4个节点在服务中 Security is off.
ubuntu 16.04.3 lts版
java 8
描述
我在flink-1.4.0中有一个java作业,它以特定的路径写入hdfs。更新到flink-1.4.2后,hadoop出现以下错误,抱怨用户没有对给定路径的写入权限:
WARN org.apache.hadoop.security.UserGroupInformation: PriviledgedActionException as:xng (auth:SIMPLE) cause:org.apache.hadoop.security.AccessControlException: Permission denied: user=user1, access=WRITE, inode="/user":hdfs:hadoop:drwxr-xr-x
注:
如果我在flink-1.4.0上运行同一个作业,不管我对作业的依赖关系是哪个版本的flink(1.4.0或1.4.2),错误都会消失
另外,如果从ide运行job main方法并传递相同的参数,则不会出现上述错误。
有什么问题吗?或者如何修复?
暂无答案!
目前还没有任何答案,快来回答吧!