new user does not run job use flink cli

[❤]

flink-conf.yaml

jobmanager.heap.size: 1024m

taskmanager.heap.size: 6144m

taskmanager.numberOfTaskSlots: 3

parallelism.default: 1

high-availability: zookeeper

high-availability.zookeeper.quorum: 10.1.1.15:2181,10.1.1.16:2181,10.1.1.17:2181

high-availability.zookeeper.path.root: /flink

high-availability.cluster-id: /flink_one

high-availability.storageDir: hdfs://user/flink/recovery

state.checkpoints.dir: hdfs://10.1.1.5:8020/user/flink/flink-checkpoints

state.savepoints.dir: hdfs://10.1.1.5:8020/user/flink/flink-checkpoints

masters

10.1.1.12:8081

10.1.1.13:8081

10.1.1.14:8081

slaves

10.1.1.12

10.1.1.13

10.1.1.14

flink cluster start with user flink. flink user run any job are OK,but other user , such as add new user test ,run FLINK_HOME/examples/batch/WordCount.jar error.

[Biao Liu]

Hi,

Do you mean job submission is OK with local user name "flink", but not for other users?

Have you ever checked the authorization of "hdfs://user/flink/recovery"? I guess other users do not have the access right. 

&#38;#38;#38;#38;#38;#38;#10084; <[hidden email]> 于2019年7月11日周四 上午11:55写道：

flink-conf.yaml

jobmanager.heap.size: 1024m

taskmanager.heap.size: 6144m

taskmanager.numberOfTaskSlots: 3

parallelism.default: 1

high-availability: zookeeper

high-availability.zookeeper.quorum: 10.1.1.15:2181,10.1.1.16:2181,10.1.1.17:2181

high-availability.zookeeper.path.root: /flink

high-availability.cluster-id: /flink_one

high-availability.storageDir: hdfs://user/flink/recovery

state.checkpoints.dir: hdfs://10.1.1.5:8020/user/flink/flink-checkpoints

state.savepoints.dir: hdfs://10.1.1.5:8020/user/flink/flink-checkpoints

masters

10.1.1.12:8081

10.1.1.13:8081

10.1.1.14:8081

slaves

10.1.1.12

10.1.1.13

10.1.1.14

flink cluster start with user flink. flink user run any job are OK,but other user , such as add new user test ,run FLINK_HOME/examples/batch/WordCount.jar error.