pyflink.datastream.stream_execution_environment.StreamExecutionEnvironment.set_max_parallelism#
- StreamExecutionEnvironment.set_max_parallelism(max_parallelism: int) pyflink.datastream.stream_execution_environment.StreamExecutionEnvironment [source]#
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.