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 >
