flink-user mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From Aljoscha Krettek <aljos...@apache.org>
Subject Re: Different results on local and on cluster
Date Fri, 01 Jul 2016 16:58:41 GMT
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 <pompermaier@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
>

Mime
View raw message