GitHub user maqingxiang opened a pull request:
https://github.com/apache/flink/pull/5357
[hotfix] Eliminate the conditions of parallelism in isChainable
When building StreamGraph, the restriction is added, and the upstream and
downstream nodes of the forward are required to have the same parallelism.
When we added edge, we added the following restrictions.
`if (partitioner instanceof ForwardPartitioner) {
if (upstreamNode.getParallelism() !=
downstreamNode.getParallelism()) {
throw new
UnsupportedOperationException("Forward partitioning does not allow " +
"change of parallelism.
Upstream operation: " + upstreamNode + " parallelism: " +
upstreamNode.getParallelism() +
", downstream
operation: " + downstreamNode + " parallelism: " +
downstreamNode.getParallelism() +
" You must use another
partitioning strategy, such as broadcast, rebalance, shuffle or global.");
}
}`
You can merge this pull request into a Git repository by running:
$ git pull https://github.com/maqingxiang/flink fix-isChainable
Alternatively you can review and apply these changes as the patch at:
https://github.com/apache/flink/pull/5357.patch
To close this pull request, make a commit to your master/trunk branch
with (at least) the following in the commit message:
This closes #5357
----
commit fbdd387215f9f8e26742897ec0ba86c411a7c362
Author: maqingxiang-it <maqingxiang-it@...>
Date: 2018-01-25T07:45:06Z
Eliminate the conditions of parallelism in isChainable
----
---
