Github user mxm commented on the pull request:
https://github.com/apache/flink/pull/488#issuecomment-83433378
Let me explain how I made out the relevant API facing methods to deprecate.
Since I changed all calls to set the parallelism to `getParallelism` or
`setParallelism` I did not have to change classes which already used these
methods. To find the remaining which used `setDegreeOfParalleism` or
`getDegreeOfParalleism` method, I did a regexp search in the Java and Scala
classes:
Java: `public .* (get|set)DegreeOfParallelism`
`ExecutionConfig`
`Operator`
`CollectionEnvironment`
`ExecutionEnvironment`
`StreamExecutionEnvironment`
`SpargelIteration`
Scala: `def (get|set)DegreeOfParallelism`
`ExecutionEnvironment`
`StreamExecutionEnvironment`
In these classes I deprecated the methods, and made them call the new
methods `getParallelism` and `setParallelism`. That's how I verified this pull
request is not API breaking. For you inspection, I've created a separate commit
with these changes. The deprecated methods are also covered in the
documentation about how to change the parallelism:
http://ci.apache.org/projects/flink/flink-docs-master/programming_guide.html#parallel-execution
---
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 [email protected] or file a JIRA ticket
with INFRA.
---
