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?

Reply via email to