Hi Marco, I agree with you that the -m help message is misleading but I do not think it has changed between releases. You can specify the address of the jobmanager or, for example, you can put "-m yarn-cluster" and depending on your environment setup Flink will pick up a session cluster or will create a per-job cluster. This was always the case.
For the -t and -e the change is that -e was deprecated (although still active) in favour of -t. But it still has the same meaning. Finally on how to run Flink on EMR, I am not an expert so I will pull in Till who may have some input. Cheers, Kostas On Mon, Nov 9, 2020 at 10:46 PM Marco Villalobos <mvillalo...@kineteque.com> wrote: > > 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? >
