项目场景:

使用Flink 提交任务报zookeeper目前权限错误:
org.apache.flink.shaded.zookeeper3.org.apache.zookeeper.KeeperException$NoAuthException: KeeperErrorCode = NoAuth for /flink_base/flinkserver-193793206

问题描述

flink提交任务报错:

org.apache.flink.shaded.zookeeper3.org.apache.zookeeper.KeeperException$NoAuthException: KeeperErrorCode = NoAuth for /flink_base/flinkserver-193793206


原因分析:

/flink_base目录 对应提交用户没有权限
登录zookeeper cli

zkCli.sh  -server xxxx:xxx

通过命令检查目录权限:

[zk: xxxxx(CONNECTED) 2] getAcl /flink_base
'sasl,'test@HADOOP.COM
: cdrwa

只有一个用户


解决方案:

通过以下命令设置目录权限:

setAcl /flink_base world:anyone:cdrwa

查询:

[zk: xxxx(CONNECTED) 9] getAcl /flink_base
'world,'anyone
: cdrwaS

再次提交任务解决

更多推荐