flink-user mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From Flavio Pompermaier <pomperma...@okkam.it>
Subject Re: Different results on local and on cluster
Date Fri, 01 Jul 2016 17:05:57 GMT
what do you mean exactly?
On 1 Jul 2016 18:58, "Aljoscha Krettek" <aljoscha@apache.org> wrote:

> Hi,
> do you have any data in the coGroup/groupBy operators that you use,
> besides the input data?
>
> Cheers,
> Aljoscha
>
> On Fri, 1 Jul 2016 at 14:17 Flavio Pompermaier <pompermaier@okkam.it>
> wrote:
>
>> Hi to all,
>> I have a Flink job that computes data correctly when launched locally
>> from my IDE while it doesn't when launched on the cluster.
>>
>> Is there any suggestion/example to understand the problematic operators
>> in this way?
>> I think the root cause is the fact that some operator (e.g.
>> coGroup/groupBy,etc), which I assume to have all the data for a key, maybe
>> it is not (because the data is partitioned among nodes).
>>
>> Any help is appreciated,
>> Flavio
>>
>

Mime
View raw message