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.
