flink-user mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From Flavio Pompermaier <pomperma...@okkam.it>
Subject Different results on local and on cluster
Date Fri, 01 Jul 2016 12:17:12 GMT
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,

View raw message