Github user maqingxiang commented on the issue: https://github.com/apache/flink/pull/5357 Thanks for your review @zentol As far as I know, If the partitioner of the edge is forward, then their parallelism must be the same. Maybe I'm completely missing something...
---