[
https://issues.apache.org/jira/browse/FLINK-815?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Robert Metzger resolved FLINK-815.
----------------------------------
Resolution: Fixed
Fix Version/s: pre-apache-0.5
0.6-incubating
This issue has been resolved in this commit:
https://github.com/stratosphere/stratosphere/commit/39fd71ae04faa2761579afdf4f13f97340b34c34
> Improve partitioning hash function
> ----------------------------------
>
> Key: FLINK-815
> URL: https://issues.apache.org/jira/browse/FLINK-815
> Project: Flink
> Issue Type: Bug
> Reporter: GitHub Import
> Labels: github-import
> Fix For: pre-apache, 0.6-incubating, pre-apache-0.5
>
>
> Right now, the partitioner (`OutputEmitter`) used directly the hash code
> produced by the partitioning elements. Types like `Integer` have very weak
> hash functions, so the hash partitioning is very susceptible to skew there.
> ---------------- Imported from GitHub ----------------
> Url: https://github.com/stratosphere/stratosphere/issues/815
> Created by: [StephanEwen|https://github.com/StephanEwen]
> Labels: runtime,
> Milestone: Release 0.6 (unplanned)
> Created at: Wed May 14 21:40:36 CEST 2014
> State: open
--
This message was sent by Atlassian JIRA
(v6.2#6252)
