Dear user,
If you start your Flink job with a command line, you can also set the parallelism (using
-p parallelism):
./bin/flink run -p 10 ../word-count.jar
You can also set the parallelism of your entire program by doing this:
StreamExecutionEnvironment env = StreamExecutionEnvironment.getExecutionEnvironment();
env.setParallelism(10);
Note:
The parallelism degree is the parallelism degree of your entire program. If you do not set the parallel degree coverage for each operator, the parallelism degree of each operator is the value of the parallelism degree set here.