Как Flink поддерживает локальный режим?

Question

Я бы запустил мое приложение flink на одной машине, и я хочу указать 20 ядер для этого приложения.На самом деле, я хочу использовать в качестве примера искру:

spark-submit --master local[20]

Я бы спросил, как я подаю заявку на Flink на одной машине, как это делает свеча.

Answer 1

Одним из вариантов является установка числа параллелизм в качестве команды Cli

. / Bin / flink run -p 10 ../examples/WordCount-java .jar