new user does not run job use flink cli

["&#38;#38;#38;#38;#38;#38;#10084;" <79...@qq.com>]

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.

Re: new user does not run job use flink cli

[Biao Liu <mm...@gmail.com>]

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; <79...@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.
>
>