When trying to set a different parallelism on an operator with reinterpretAsKeyedStream Flink throws an java.lang.UnsupportedOperationException exception: Forward partitioning does not allow change of parallelism. Upstream operation: .... You must use another partitioning strategy, such as broadcast, rebalance, shuffle or global.

Tested this on Flink 1.18.1.