Repository: flink Updated Branches: refs/heads/master 8134f4433 -> 98d182603
[FLINK-5249] [docs] Fix description of datastream rescaling to match the figure. This closes #2932. Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/96239b30 Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/96239b30 Diff: http://git-wip-us.apache.org/repos/asf/flink/diff/96239b30 Branch: refs/heads/master Commit: 96239b3056fa437f450e414d94e61157b77f7e07 Parents: 8134f44 Author: David Anderson <da...@alpinegizmo.com> Authored: Sun Dec 4 15:32:23 2016 +0100 Committer: Fabian Hueske <fhue...@apache.org> Committed: Tue Dec 6 10:52:50 2016 +0100 ---------------------------------------------------------------------- docs/dev/datastream_api.md | 13 ++++++------- 1 file changed, 6 insertions(+), 7 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/flink/blob/96239b30/docs/dev/datastream_api.md ---------------------------------------------------------------------- diff --git a/docs/dev/datastream_api.md b/docs/dev/datastream_api.md index 57d2e4b..ef4a394 100644 --- a/docs/dev/datastream_api.md +++ b/docs/dev/datastream_api.md @@ -1008,19 +1008,18 @@ dataStream.rebalance(); The subset of downstream operations to which the upstream operation sends elements depends on the degree of parallelism of both the upstream and downstream operation. For example, if the upstream operation has parallelism 2 and the downstream operation - has parallelism 4, then one upstream operation would distribute elements to two + has parallelism 6, then one upstream operation would distribute elements to three downstream operations while the other upstream operation would distribute to the other - two downstream operations. If, on the other hand, the downstream operation has parallelism - 2 while the upstream operation has parallelism 4 then two upstream operations would - distribute to one downstream operation while the other two upstream operations would - distribute to the other downstream operations. + three downstream operations. If, on the other hand, the downstream operation has parallelism + 2 while the upstream operation has parallelism 6 then three upstream operations would + distribute to one downstream operation while the other three upstream operations would + distribute to the other downstream operation. </p> <p> In cases where the different parallelisms are not multiples of each other one or several downstream operations will have a differing number of inputs from upstream operations. - - </p> </p> + <p> Please see this figure for a visualization of the connection pattern in the above example: </p>
