[
https://issues.apache.org/jira/browse/FLINK-653?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Fabian Hueske closed FLINK-653.
-------------------------------
Resolution: Duplicate
Same as FLINK-1060
> Add rebalance flag for map/flatmap in new Java API
> --------------------------------------------------
>
> Key: FLINK-653
> URL: https://issues.apache.org/jira/browse/FLINK-653
> Project: Flink
> Issue Type: Improvement
> Reporter: GitHub Import
> Labels: github-import
> Fix For: pre-apache
>
>
> It would be nice to have a flag in the new Java API that triggers the input
> of a mapper to be rebalanced to compensate for skew in the data.
> Details can be found here:
> https://groups.google.com/d/msg/stratosphere-users/pIw0eyMkLd8/lmoCWXw3rz8J
> ---------------- Imported from GitHub ----------------
> Url: https://github.com/stratosphere/stratosphere/issues/653
> Created by: [mleich|https://github.com/mleich]
> Labels: enhancement, java api,
> Created at: Wed Apr 02 15:57:37 CEST 2014
> State: open
--
This message was sent by Atlassian JIRA
(v6.3.4#6332)