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 >> >
