GitHub user StefanRRichter opened a pull request:
https://github.com/apache/flink/pull/3182
[FLINK-5473] Limit MaxParallelism to 1 for non-parallel operators and
improve choice of max parallelism without explicit configuration
This PR limits the maximum parallelism for non-parallel operator to 1.
Furthermore, this improves the default behaviour if the user did not
explicitly specify a maximum parallelism. In particular, maximum parallelism
can now be derived from savepoints, allowing users that migrate from Flink 1.1
to Flink 1.2 to keep their job unchanged.
You can merge this pull request into a Git repository by running:
$ git pull https://github.com/StefanRRichter/flink recover-max-para
Alternatively you can review and apply these changes as the patch at:
https://github.com/apache/flink/pull/3182.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 #3182
----
commit 20d0a3fc88c85a71b692c5408fc7b2fd33da8ff2
Author: Stefan Richter <s.rich...@data-artisans.com>
Date: 2017-01-16T13:31:22Z
[FLINK-5473] Limit max parallelism to 1 for non-parallel operators
commit f6081f319b7f2ef8615557743d906bc4585445f7
Author: Stefan Richter <s.rich...@data-artisans.com>
Date: 2017-01-16T17:41:37Z
[FLINK-5473] Better default behaviours for unspecified maximum parallelism
----
---
If your project is set up for it, you can reply to this email and have your
reply appear on GitHub as well. If your project does not have this feature
enabled and wishes so, or if the feature is enabled but not working, please
contact infrastructure at infrastruct...@apache.org or file a JIRA ticket
with INFRA.
---
