Github user zentol commented on the issue:
https://github.com/apache/flink/pull/5357
@maqingxiang You are correct that the parallelism check is redundant, but
that doesn't automatically mean that it should be removed.
This change imo hurts readability as the basic parallelism condition is no
longer explicit, but implicitly covered by the partitioner used.---
