From ac37f94888bd2b1e00d143688d31452b910fe406 Mon Sep 17 00:00:00 2001 From: David Anderson Date: Sun, 4 Dec 2016 15:32:23 +0100 Subject: [PATCH] In the example of rescaling, updated the description to match the figure. --- docs/dev/datastream_api.md | 13 ++++++------- 1 file changed, 6 insertions(+), 7 deletions(-) diff --git a/docs/dev/datastream_api.md b/docs/dev/datastream_api.md index 57d2e4bf1da9d..ef4a394079277 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.

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

+

Please see this figure for a visualization of the connection pattern in the above example: