在将flink-1.40更新为flink-1.4.2之后从hdfs获得写权限

8e2ybdfx  于 2021-06-01  发布在  Hadoop
关注(0)|答案(0)|浏览(289)

环境
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方法并传递相同的参数,则不会出现上述错误。
有什么问题吗?或者如何修复?

暂无答案!

目前还没有任何答案,快来回答吧!

相关问题