Github user rmetzger commented on the pull request:
https://github.com/apache/incubator-flink/pull/37#issuecomment-48535683
Yes, move them to a `test` package.
Regarding the DOP: The `./bin/stratosphere` client allows to pass a `-p`
parameter that sets the DOP for the enviroment. This way, users can change the
DOP very easily.
So by default, I would not set any DOP so that you can set it when running.
If the user has set the respective hadoop property
(`mapred.tasktracker.map.tasks.maximum`) we indeed should respect that. Flink
allows to set the DOP individually to operators, the functionality is just not
exposed via the Java API.
Can you open a JIRA for that, discuss how to implement it and then
contribute the change via a PR? (I will merge this change independently of the
change, so it won't be a blocker).
---
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.
---
