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...---
