pyflink.datastream.stream_execution_environment.StreamExecutionEnvironment.get_max_parallelism

StreamExecutionEnvironment.get_max_parallelism() → int

Gets the maximum degree of parallelism defined for the program.

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

Returns:

Maximum degree of parallelism.