pyflink.datastream.stream_execution_environment.StreamExecutionEnvironment.set_max_parallelism

StreamExecutionEnvironment.set_max_parallelism(max_parallelism: int) → StreamExecutionEnvironment

Sets the maximum degree of parallelism defined for the program. The upper limit (inclusive) is 32768.

The maximum degree of parallelism specifies the upper limit for dynamic scaling. It also defines the number of key groups used for partitioned state.

Parameters:

max_parallelism – Maximum degree of parallelism to be used for the program, with 0 < maxParallelism <= 2^15.

Returns:

This object.