I guess Aljoscha was referring to whether you also have broadcasted
input or something like it?

On Fri, Jul 1, 2016 at 7:05 PM, Flavio Pompermaier <pomperma...@okkam.it> wrote:
> what do you mean exactly?
>
> On 1 Jul 2016 18:58, "Aljoscha Krettek" <aljos...@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 <pomperma...@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

Reply via email to