Dear Fabian,
Can you have a look into this issue. What actions will be required to
resolve this one?
https://issues.apache.org/jira/browse/FLINK-1725
Regards,
Anis
On Wed, Feb 15, 2017 at 6:36 PM, Fabian Hueske wrote:
> Hi Anis,
>
> Flink uses regular hash-partitioning to shuffle records an
Hi Anis,
Flink uses regular hash-partitioning to shuffle records and does not have a
mechanism to counter data skew (other than scaling out).
Heterogeneous hardware can (to some extend) be addressed by adapting the
number of processing slots (or task managers) per machine, i.e., configure
fewer sl
