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;#10084; <799326...@qq.com> 于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. > >
