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