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
