user test can't run flink-1.8.1 wordcount

2019-07-12 Thread ❤
Dear all,I got some issues about flink that Flink-1.8.1??s HA cluster to execute test cases on the cli client to start the users of outside the cluster. For instance, the command ??flink run WordCounter.jar?? it??s doesn??s work. So, could you give me some successful examples, please.

new user does not run job use flink cli

2019-07-10 Thread ❤
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-availabil