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?