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
