Github user atsikiridis commented on the pull request:
https://github.com/apache/incubator-flink/pull/37#issuecomment-48534266
Definitely, this should not stay 1. I just left it here for simplicity.
In my new branch it is the the maximum of (
```mapred.tasktracker.map.tasks.maximum``` and
```mapred.tasktracker.reduce.tasks.maximum``` ) which are the "slots" of tasks
per node. What do you think?
The problem here is that in flink it is a degree for all operators in an
environment (if I'm not mistaken) so if for example, DOP = 3 it will be 3
mappers and 3 reducers. What happens if I want 3 mappers in parallel and 1
reducer ? Is there actually a way to set parallelism per operator with the
current APIs ?
---
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.
---
