Github user gyfora commented on the pull request:
https://github.com/apache/flink/pull/747#issuecomment-113078373
Alright I think I fixed the issues, now the only thing remains is to add
partitioning setting to the API.
State partitioning should be a property of the operator therefore it should
be set afterwards like parallelism.
For example: stream.map(Mapper).setStatePartitioner(...)
This is quite tricky however as the state partitioner should affect the
partitioning scheme of the input streams (otherwise it makes no sense). I see
two approaches here: 1. simply overwrite the partitioning without warning
2. Only overwrite in case it is not defined (forward), otherwise throw
exception stating that partitioning cannot be different from statePartitioning
---
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.
---
