The flink CLI documentation says that the -m option is to specify the job manager.
but the examples are passing in an execution target. I am quite confused by this. ./bin/flink run -m yarn-cluster \ ./examples/batch/WordCount.jar \ --input hdfs:///user/hamlet.txt --output hdfs:///user/wordcount_out So what is it? I am trying to run Flink in EMR 6.1.0 but I have failed. It appears as though some of the command line parameters changed from version 1.10 to 1.11. For example, -yna is now -ynm. -e is now -t. But I am still confused by the -m option in both documentation. Can somebody please explain?