flink-issues mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From maqingxiang <...@git.apache.org>
Subject [GitHub] flink pull request #5357: [hotfix] Eliminate the conditions of parallelism i...
Date Thu, 25 Jan 2018 07:53:57 GMT
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

----


---

Mime
View raw message